From 5d1fc27e7a95a232211be11815a9a1f1e644a719 Mon Sep 17 00:00:00 2001 From: Kai Moritz 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