This is an automated email from the ASF dual-hosted git repository.
schofielaj 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 dbbc45f7a00 KAFKA-19416: Reduce running time of ShareConsumerTest
(#19992)
dbbc45f7a00 is described below
commit dbbc45f7a00ff9970fbab7daf3d9afbe6817ee11
Author: Lan Ding <[email protected]>
AuthorDate: Thu Jun 19 22:30:23 2025 +0800
KAFKA-19416: Reduce running time of ShareConsumerTest (#19992)
Configure tests in ShareConsumer to run exclusively in Raft-Isolated
mode to reduce execution time.
Reviewers: Andrew Schofield <[email protected]>, Jhen-Yung Hsu
<[email protected]>, Ken Huang <[email protected]>
---
.../test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
index 42ba850f2ce..62edeadd1d7 100644
---
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
+++
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
@@ -56,6 +56,7 @@ import org.apache.kafka.common.test.ClusterInstance;
import org.apache.kafka.common.test.api.ClusterConfigProperty;
import org.apache.kafka.common.test.api.ClusterTest;
import org.apache.kafka.common.test.api.ClusterTestDefaults;
+import org.apache.kafka.common.test.api.Type;
import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.coordinator.group.GroupConfig;
import org.apache.kafka.coordinator.group.modern.share.ShareGroupConfig;
@@ -111,6 +112,7 @@ import static org.junit.jupiter.api.Assertions.fail;
@Timeout(1200)
@Tag("integration")
@ClusterTestDefaults(
+ types = {Type.KRAFT},
serverProperties = {
@ClusterConfigProperty(key = "auto.create.topics.enable", value =
"false"),
@ClusterConfigProperty(key = "group.share.partition.max.record.locks",
value = "10000"),
