From ef6fb5e6d1413376189cf6c4016a2c94c469fd50 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 Feb 2024 09:50:44 +0100
Subject: [PATCH] WIP:wait--FIX

---
 src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java | 2 ++
 1 file changed, 2 insertions(+)

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 72f8436a..02856466 100644
--- 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));
 
-- 
2.20.1