This is an automated email from the ASF dual-hosted git repository.
frankvicky pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new fa4d8836d39 MINOR: DescribeAuthorizedOperationsTest cluster setting
has been overridden (#20012)
fa4d8836d39 is described below
commit fa4d8836d39365200e91eb7506a01032ad0e69bc
Author: Ken Huang <[email protected]>
AuthorDate: Sun Jun 22 21:42:03 2025 +0800
MINOR: DescribeAuthorizedOperationsTest cluster setting has been overridden
(#20012)
The old approach `OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG` will override
`OFFSETS_TOPIC_PARTITIONS_CONFIG` config, this behaviour is not
expected, we should fix it.
Reviewers: TengYao Chi <[email protected]>
---
.../kafka/clients/admin/DescribeAuthorizedOperationsTest.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java
index ef7b89a830d..32677ee22f0 100644
---
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java
+++
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java
@@ -69,8 +69,10 @@ public class DescribeAuthorizedOperationsTest {
return List.of(
ClusterConfig.defaultBuilder()
.setTypes(Set.of(Type.KRAFT))
-
.setServerProperties(Map.of(GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG,
"1"))
-
.setServerProperties(Map.of(GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG,
"1"))
+ .setServerProperties(Map.of(
+ GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG,
"1",
+
GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG, "1"
+ ))
.setBrokerSecurityProtocol(SecurityProtocol.SASL_PLAINTEXT)
.setControllerSecurityProtocol(SecurityProtocol.SASL_PLAINTEXT)
.build()