WIP:wait

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 e681997994b84f323372e7d317eb6316808a9408..7108ffb01d4b246ecf7c8c9d925f184afc8ab711 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -44,7 +44,6 @@ class KafkaHandoverIT extends AbstractHandoverIT
             .block())
         .forEach(result -> log.info("{}", result));
 
-    Thread.sleep(10000);
     receiveMessages(chatRoom).subscribe(message -> log.info("message: {}", message));
 
     Thread.sleep(1000000);
@@ -210,8 +209,8 @@ class KafkaHandoverIT extends AbstractHandoverIT
         result.getStdout());
 
     BACKEND_1.start();
-    BACKEND_2.start();
-    BACKEND_3.start();
+    // BACKEND_2.start();
+    // BACKEND_3.start();
   }
 
   static Network NETWORK = Network.newNetwork();