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 0285646..cc5039e 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -40,7 +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)))
+            .retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1)))
             .block())
         .forEach(result -> log.info("{}", result));