From: Kai Moritz <kai@juplo.de>
Date: Sat, 24 Feb 2024 12:18:21 +0000 (+0100)
Subject: WIP:setup
X-Git-Tag: rebase--2024-02-26--19-46~17
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=f335866f27ad4aaa0c5788c1b8c7f7ee9c76711f;p=demos%2Fkafka%2Fchat

WIP:setup
---

diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
index 7b338035..7f564637 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -113,6 +113,8 @@ class KafkaHandoverIT extends AbstractHandoverIT
   static void setUpDocker() throws IOException, InterruptedException
   {
     KAFKA.start();
+    HAPROXY.start();
+
 
     Container.ExecResult result;
     result = KAFKA.execInContainer(
@@ -145,10 +147,8 @@ class KafkaHandoverIT extends AbstractHandoverIT
         result.getStdout());
 
     BACKEND_1.start();
-    BACKEND_2.start();
-    BACKEND_3.start();
-
-    HAPROXY.start();
+    // BACKEND_2.start();
+    // BACKEND_3.start();
   }
 
   static Network NETWORK = Network.newNetwork();
@@ -233,7 +233,6 @@ class KafkaHandoverIT extends AbstractHandoverIT
               "/usr/local/etc/haproxy/sharding.map",
               BindMode.READ_WRITE)
           .withExposedPorts(8400) // , 8401, 8404, 5555)
-          .dependsOn(BACKEND_1, BACKEND_2, BACKEND_3)
           .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("HAPROXY"));
 
   @EqualsAndHashCode
diff --git a/src/test/resources/haproxy.cfg b/src/test/resources/haproxy.cfg
index b19f71f1..077b67cc 100644
--- a/src/test/resources/haproxy.cfg
+++ b/src/test/resources/haproxy.cfg
@@ -6,6 +6,7 @@ defaults
   timeout server 10m
   timeout http-request 10s
   log global
+  default-server init-addr last,libc,none
 
 global
   stats socket ipv4@:8401 level admin