From 7c8ce6a41b6bd2ae7942e08dded8f1c93b7ffd2b Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 8 Mar 2024 09:14:14 +0100 Subject: [PATCH] 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. --- .../java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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++) { -- 2.20.1