From 31a52c902f62875b66359616718f72e8fe2e6307 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 23 Feb 2024 16:52:36 +0100
Subject: [PATCH] WIP:startup
---
.../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 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
--
2.20.1