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();