WIP:startup
authorKai Moritz <kai@juplo.de>
Fri, 23 Feb 2024 15:52:36 +0000 (16:52 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 23 Feb 2024 15:52:36 +0000 (16:52 +0100)
src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java

index 800d17e..c6df4f0 100644 (file)
@@ -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