From: Kai Moritz <kai@juplo.de>
Date: Fri, 23 Feb 2024 15:52:36 +0000 (+0100)
Subject: WIP:startup
X-Git-Tag: rebase--2024-02-26--19-46~23
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=31a52c902f62875b66359616718f72e8fe2e6307;p=demos%2Fkafka%2Fchat

WIP:startup
---

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 800d17eb..c6df4f08 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -87,7 +87,7 @@ class KafkaHandoverIT extends AbstractHandoverIT
           .withListener(() -> "kafka:9999")
           .withEnv("KAFKA_NUM_PARTITIONS", "10")
           .withKraft()
-          .waitingFor(Wait.forLogMessage(".*Kafka Server started.*\\n", 1))
+          .waitingFor(Wait.forLogMessage(".*Kafka\\ Server\\ started.*\\n", 1))
           .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("KAFKA"));
 
   @Container
@@ -107,7 +107,7 @@ class KafkaHandoverIT extends AbstractHandoverIT
               "--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
           )
           .dependsOn(kafka)
-          .waitingFor(Wait.forHttp("/actuator/health"))
+          .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
           .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-1"));
 
   @Container
@@ -127,7 +127,7 @@ class KafkaHandoverIT extends AbstractHandoverIT
               "--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
           )
           .dependsOn(kafka)
-          .waitingFor(Wait.forHttp("/actuator/health"))
+          .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
           .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-2"));
 
   @Container
@@ -147,7 +147,7 @@ class KafkaHandoverIT extends AbstractHandoverIT
               "--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
           )
           .dependsOn(kafka)
-          .waitingFor(Wait.forHttp("/actuator/health"))
+          .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
           .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-3"));
 
   @Container