From f335866f27ad4aaa0c5788c1b8c7f7ee9c76711f Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 24 Feb 2024 13:18:21 +0100 Subject: [PATCH] WIP:setup --- .../de/juplo/kafka/chat/backend/KafkaHandoverIT.java | 9 ++++----- src/test/resources/haproxy.cfg | 1 + 2 files changed, 5 insertions(+), 5 deletions(-) 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 -- 2.20.1