WIP:neu
authorKai Moritz <kai@juplo.de>
Thu, 22 Feb 2024 21:10:43 +0000 (22:10 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 23 Feb 2024 15:40:03 +0000 (16:40 +0100)
src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java

index d9aa444..00b7a30 100644 (file)
@@ -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:9999")
           .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:9092"
+              "--chat.backend.kafka.bootstrap-servers=kafka:9999"
           )
           .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:9092"
+              "--chat.backend.kafka.bootstrap-servers=kafka:9999"
           )
           .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:9092"
+              "--chat.backend.kafka.bootstrap-servers=kafka:9999"
           )
           .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-3"));