From: Kai Moritz Date: Fri, 8 Mar 2024 08:14:14 +0000 (+0100) Subject: test: HandoverIT - RED - Started a second backend X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=7c8ce6a41b6bd2ae7942e08dded8f1c93b7ffd2b;p=demos%2Fkafka%2Fchat test: HandoverIT - RED - Started a second backend * A second backend is started, after the writers and the listener were instanciated. * The test fails, because the listener does not see messages, that are send by the writers after the rebalance finishes. --- 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 4d245fd3..d86ae9a9 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java @@ -72,8 +72,9 @@ public abstract class AbstractHandoverIT "Received message: {}", message)); - log.info("Sleeping for 3 seconds..."); - Thread.sleep(3000); + log.info("Starting backend-2..."); + containers.startBackend(containers.backend2, testWriters); + log.info("backend-2 started!"); for (int i = 0; i < NUM_CLIENTS; i++) {