From 5d1fc27e7a95a232211be11815a9a1f1e644a719 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 24 Feb 2024 12:39:04 +0100
Subject: [PATCH] WIP:setup
---
.../java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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"));
--
2.20.1