WIP:test: HandoverIT-POC - Clients are stopped after some time

diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
index 19d69049c46ce32f6c521f397fcba1f623fd3fe1..7ab65f6f8faf62af15ae3188acc7b38d8c1a4da8 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
@@ -65,7 +65,7 @@ public abstract class AbstractHandoverIT
 
     Flux
         .fromArray(chatRooms)
-        .flatMap(chatRoom ->receiveMessages(chatRoom).take(2))
+        .flatMap(chatRoom ->receiveMessages(chatRoom).take(50))
         .doOnNext(message -> log.info("message: {}", message))
         .then()
         .block();