WIP:wait--FIX

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 72f8436..0285646 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -20,6 +20,7 @@ import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.utility.DockerImageName;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.util.retry.Retry;
 
 import java.io.IOException;
 import java.time.Duration;
@@ -39,6 +40,7 @@ class KafkaHandoverIT extends AbstractHandoverIT
         .mapToObj(i ->sendMessage(chatRoom, user, "Message #" + i))
         .map(result -> result
             .map(MessageTo::toString)
+            .retryWhen(Retry.backoff(10, Duration.ofSeconds(1)))
             .block())
         .forEach(result -> log.info("{}", result));