From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 Feb 2024 08:50:44 +0000 (+0100)
Subject: WIP:wait--FIX
X-Git-Tag: rebase--2024-02-26--19-46~9
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ef6fb5e6d1413376189cf6c4016a2c94c469fd50;p=demos%2Fkafka%2Fchat

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 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));