This is an automated email from the ASF dual-hosted git repository.
mimaison 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 1d1820c66a2 MINOR: Speed up AuthorizerIntegrationTest (#22785)
1d1820c66a2 is described below
commit 1d1820c66a22c558bf24481ca772d4462a3df2d8
Author: Jiayáo Sun <[email protected]>
AuthorDate: Thu Jul 9 01:52:06 2026 +1200
MINOR: Speed up AuthorizerIntegrationTest (#22785)
AuthorizerIntegrationTest runs with a single broker, but the share
coordinator state topic defaults to replication.factor=3, min.isr=2.
This causes unnecessary retries when the test exercises share group
state APIs.
Set share.coordinator.state.topic.replication.factor=1,
share.coordinator.state.topic.min.isr=1 for this test.
Reviewers: Mickael Maison <[email protected]>
---
.../integration/kafka/api/AbstractAuthorizerIntegrationTest.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/core/src/test/scala/integration/kafka/api/AbstractAuthorizerIntegrationTest.scala
b/core/src/test/scala/integration/kafka/api/AbstractAuthorizerIntegrationTest.scala
index f852a707d9b..0c510850b94 100644
---
a/core/src/test/scala/integration/kafka/api/AbstractAuthorizerIntegrationTest.scala
+++
b/core/src/test/scala/integration/kafka/api/AbstractAuthorizerIntegrationTest.scala
@@ -28,6 +28,7 @@ import
org.apache.kafka.common.resource.ResourceType.{CLUSTER, GROUP, TOPIC, TRA
import org.apache.kafka.common.security.auth.{AuthenticationContext,
KafkaPrincipal}
import
org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
import org.apache.kafka.coordinator.group.GroupCoordinatorConfig
+import org.apache.kafka.coordinator.share.ShareCoordinatorConfig
import org.apache.kafka.coordinator.transaction.TransactionLogConfig
import org.apache.kafka.metadata.authorizer.StandardAuthorizer
import org.apache.kafka.server.config.ServerConfigs
@@ -119,6 +120,8 @@ class AbstractAuthorizerIntegrationTest extends
BaseRequestTest {
properties.put(GroupCoordinatorConfig.CONSUMER_GROUP_REGEX_REFRESH_INTERVAL_MS_CONFIG,
"10000")
properties.put(GroupCoordinatorConfig.SHARE_GROUP_ASSIGNMENT_INTERVAL_MS_CONFIG,
"0")
properties.put(GroupCoordinatorConfig.STREAMS_GROUP_ASSIGNMENT_INTERVAL_MS_CONFIG,
"0")
+
properties.put(ShareCoordinatorConfig.STATE_TOPIC_REPLICATION_FACTOR_CONFIG,
"1")
+ properties.put(ShareCoordinatorConfig.STATE_TOPIC_MIN_ISR_CONFIG, "1")
properties.put(TransactionLogConfig.TRANSACTIONS_TOPIC_PARTITIONS_CONFIG,
"1")
properties.put(TransactionLogConfig.TRANSACTIONS_TOPIC_REPLICATION_FACTOR_CONFIG,
"1")
properties.put(TransactionLogConfig.TRANSACTIONS_TOPIC_MIN_ISR_CONFIG, "1")
