From 590d03453564c39d6163f713a655bce84d234ada Mon Sep 17 00:00:00 2001 From: Michael Edgar Date: Thu, 7 Nov 2024 17:36:42 -0500 Subject: [PATCH] Set Kafka `group.initial.rebalance.delay.ms` to `0` in tests Signed-off-by: Michael Edgar --- .../kafka/systemtest/deployment/DeploymentManager.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/api/src/test/java/com/github/streamshub/console/kafka/systemtest/deployment/DeploymentManager.java b/api/src/test/java/com/github/streamshub/console/kafka/systemtest/deployment/DeploymentManager.java index fbdfd01d2..dcf876f9e 100644 --- a/api/src/test/java/com/github/streamshub/console/kafka/systemtest/deployment/DeploymentManager.java +++ b/api/src/test/java/com/github/streamshub/console/kafka/systemtest/deployment/DeploymentManager.java @@ -189,7 +189,10 @@ private KafkaContainer deployStrimziKafka() { .withLabels(TEST_CONTAINER_LABELS) .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("systemtests.plain-kafka"), true)) .withCreateContainerCmdModifier(cmd -> cmd.withName(name("plain-kafka"))) - .withKafkaConfigurationMap(Map.of("auto.create.topics.enable", "false")) + .withKafkaConfigurationMap(Map.of( + "auto.create.topics.enable", "false", + "group.initial.rebalance.delay.ms", "0" + )) .withNetwork(testNetwork); container.start();