From: Kai Moritz Date: Fri, 8 Mar 2024 08:14:14 +0000 (+0100) Subject: test: HandoverIT-POC - RED - Started a second backend X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=5c5fa66f4395bafe3cce3b267314ac925e7af5ec;p=demos%2Fkafka%2Fchat test: HandoverIT-POC - 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 86875c59..ae0f3a60 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 2 seconds..."); - Thread.sleep(2000); + log.info("Starting backend-2..."); + containers.startBackend(containers.backend2, testWriters); + log.info("backend-2 started!"); for (int i = 0; i < NUM_CLIENTS; i++) {