From: Kai Moritz <kai@juplo.de>
Date: Sat, 24 Feb 2024 11:39:04 +0000 (+0100)
Subject: WIP:setup
X-Git-Tag: rebase--2024-02-26--19-46~20
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=5d1fc27e7a95a232211be11815a9a1f1e644a719;p=demos%2Fkafka%2Fchat

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 0feed857..6256d706 100644
--- 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"));