From: Kai Moritz Date: Sun, 25 Feb 2024 09:00:51 +0000 (+0100) Subject: WIP:wait--FIX X-Git-Tag: rebase--2024-02-26--19-46~8 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=76de914bcb4830ddd82cf7b12fa98610dbe77daa;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 02856466..cc5039ed 100644 --- 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));