WIP:setup

diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
index 0feed85..6256d70 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -126,11 +126,11 @@ class KafkaHandoverIT extends AbstractHandoverIT
 
   @Container
   GenericContainer<?> setup =
-      new GenericContainer<>("confluentinc/cp-kcat:7.4.1")
+      new GenericContainer<>("confluentinc/cp-kcat:7.4.0")
           .withCreateContainerCmdModifier(cmd -> cmd.withEntrypoint("sh", "-c"))
       .withNetwork(network)
       .withCommand(
-          "kafka-topics --bootstrap-server kafka:9999 --create --topic info_channel --partitions 3",
+          "kafka-topics --bootstrap-server kafka:9999 --create --topic info_channel --partitions 3; " +
           "kafka-topics --bootstrap-server kafka:9999 --create --topic data_channel --partitions 10")
       .dependsOn(kafka)
       .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("SETUP"));