X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FAbstractHandoverIT.java;h=7ab65f6f8faf62af15ae3188acc7b38d8c1a4da8;hb=319a01f87982b8cf00a0b77839b69d161f32d606;hp=19d69049c46ce32f6c521f397fcba1f623fd3fe1;hpb=49c29d08549c5915301e9f95224edf64d101f272;p=demos%2Fkafka%2Fchat

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 19d69049..7ab65f6f 100644
--- 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();