From f18c0e6c4965df164b5b6c581fbeb0b495de7988 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Thu, 22 Feb 2024 21:55:33 +0100 Subject: [PATCH] WIP:neu --- .../java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 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 f2ed69b7..d9aa4445 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java @@ -38,7 +38,7 @@ class KafkaHandoverIT extends AbstractHandoverIT new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.4.0")) .withNetwork(network) .withNetworkAliases("kafka") - .withListener(() -> "kafka:9092") + // .withListener(() -> "kafka:9092") .withKraft() .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("KAFKA")); @@ -51,7 +51,7 @@ class KafkaHandoverIT extends AbstractHandoverIT .withCommand( "--chat.backend.instance-id=backend-1", "--chat.backend.services=kafka", - "--chat.backend.kafka.bootstrap-servers=kafka:9102" + "--chat.backend.kafka.bootstrap-servers=kafka:9092" ) .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-1")); @@ -64,7 +64,7 @@ class KafkaHandoverIT extends AbstractHandoverIT .withCommand( "--chat.backend.instance-id=backend-2", "--chat.backend.services=kafka", - "--chat.backend.kafka.bootstrap-servers=kafka:9102" + "--chat.backend.kafka.bootstrap-servers=kafka:9092" ) .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-2")); @@ -77,7 +77,7 @@ class KafkaHandoverIT extends AbstractHandoverIT .withCommand( "--chat.backend.instance-id=backend-3", "--chat.backend.services=kafka", - "--chat.backend.kafka.bootstrap-servers=kafka:9102" + "--chat.backend.kafka.bootstrap-servers=kafka:9092" ) .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-3")); -- 2.20.1