projects
/
demos
/
kafka
/
chat
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
af023bc
)
test: HandoverIT-POC - RED - Started a second backend
author
Kai Moritz
<kai@juplo.de>
Fri, 8 Mar 2024 08:14:14 +0000
(09:14 +0100)
committer
Kai Moritz
<kai@juplo.de>
Fri, 22 Mar 2024 16:40:15 +0000
(17:40 +0100)
* 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.
src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
patch
|
blob
|
history
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
86875c5
..
ae0f3a6
100644
(file)
--- 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++)
{