You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by fr...@apache.org on 2025/06/22 13:42:10 UTC
(kafka) branch trunk updated: MINOR: DescribeAuthorizedOperationsTest cluster setting has been overridden (#20012)
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 <s7...@gmail.com>
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 <fr...@apache.org>
---
.../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()