From 95c9f27070845f4e51a00a0cdb3598ebaf8893f9 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 8 Mar 2024 09:14:14 +0100 Subject: [PATCH] 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. * Also changed the durations, that the setup waits for newly started backend-instances. --- .../java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java | 5 +++-- .../kafka/chat/backend/AbstractHandoverITContainers.java | 4 ++-- 2 files changed, 5 insertions(+), 4 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 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++) { diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverITContainers.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverITContainers.java index 0bf7080d..f7c377e8 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverITContainers.java +++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverITContainers.java @@ -99,7 +99,7 @@ public abstract class AbstractHandoverITContainers before = Instant.now(); Awaitility .await() - .atMost(Duration.ofSeconds(30)) + .atMost(Duration.ofSeconds(45)) .until(() -> WebClient .create(backendUri) .get() @@ -132,7 +132,7 @@ public abstract class AbstractHandoverITContainers before = Instant.now(); Awaitility .await() - .atMost(Duration.ofSeconds(30)) + .atMost(Duration.ofSeconds(15)) .until(() -> WebClient .create("http://localhost:" + haproxy.getMappedPort(8400)) .get() -- 2.39.5