Skip to content

Commit 639a6bc

Browse files
committed
add GroupCoordinatorConfig in ConsumerGroupCommandTestUtils
1 parent eb9cfb0 commit 639a6bc

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandTestUtils.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@
4444
import static kafka.test.annotation.Type.KRAFT;
4545
import static kafka.test.annotation.Type.ZK;
4646
import static org.apache.kafka.coordinator.group.GroupCoordinatorConfig.GROUP_COORDINATOR_REBALANCE_PROTOCOLS_CONFIG;
47+
import static org.apache.kafka.coordinator.group.GroupCoordinatorConfig.GROUP_INITIAL_REBALANCE_DELAY_MS_CONFIG;
4748
import static org.apache.kafka.coordinator.group.GroupCoordinatorConfig.NEW_GROUP_COORDINATOR_ENABLE_CONFIG;
4849
import static org.apache.kafka.coordinator.group.GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG;
4950
import static org.apache.kafka.coordinator.group.GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG;
@@ -89,6 +90,7 @@ static List<ClusterConfig> forConsumerGroupCoordinator() {
8990
serverProperties.put(OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG, "1");
9091
serverProperties.put(NEW_GROUP_COORDINATOR_ENABLE_CONFIG, "true");
9192
serverProperties.put(GROUP_COORDINATOR_REBALANCE_PROTOCOLS_CONFIG, "classic,consumer");
93+
serverProperties.put(GROUP_INITIAL_REBALANCE_DELAY_MS_CONFIG, "0");
9294

9395
return Collections.singletonList(ClusterConfig.defaultBuilder()
9496
.setTypes(Collections.singleton(CO_KRAFT))
@@ -102,6 +104,7 @@ static List<ClusterConfig> forClassicGroupCoordinator() {
102104
serverProperties.put(OFFSETS_TOPIC_PARTITIONS_CONFIG, "1");
103105
serverProperties.put(OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG, "1");
104106
serverProperties.put(NEW_GROUP_COORDINATOR_ENABLE_CONFIG, "false");
107+
serverProperties.put(GROUP_INITIAL_REBALANCE_DELAY_MS_CONFIG, "0");
105108

106109
return Collections.singletonList(ClusterConfig.defaultBuilder()
107110
.setTypes(Stream.of(ZK, KRAFT).collect(Collectors.toSet()))

0 commit comments

Comments
 (0)