From d6285c99580cf17465182b68c68ae9a3674ae7a7 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 12 Aug 2022 22:31:24 +0200 Subject: [PATCH] =?utf8?q?Compose-Setup=20und=20README.sh=20f=C3=BCr=20die?= =?utf8?q?ses=20Beispiel=20repariert?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Zuvor war in dem Setup noch ein Producer konfiguriert, der Nachrichten vom Typ `String` geschrieben hat, so dass der Consumer _sofort_ das zeitliche gesegnet hat. * Im README-Skript wurde nicht darauf gewartet, dass der Consumer gemeldet hat, dass er ordentlich gestartet ist, bevor er nach der vermeintlichen Konsumption der Poison-Pill wieder neu gestartet wurde. --- README.sh | 6 +++--- docker-compose.yml | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/README.sh b/README.sh index 72f0c60..fe237dc 100755 --- a/README.sh +++ b/README.sh @@ -25,7 +25,9 @@ fi echo "Waiting for the Kafka-Cluster to become ready..." docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1 docker-compose up setup -docker-compose up -d producer consumer +docker-compose up -d producer +docker-compose up consumer & +while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for consumer..."; sleep 1; done sleep 5 docker-compose exec -T cli bash << 'EOF' echo "Writing poison pill into topic test..." @@ -42,5 +44,3 @@ while [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Consum http -v :8081/actuator/health http -v post :8081/actuator/shutdown docker-compose stop producer -docker-compose ps -docker-compose logs --tail=100 consumer diff --git a/docker-compose.yml b/docker-compose.yml index 159f9cb..81b98ac 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -37,7 +37,7 @@ services: command: sleep infinity producer: - image: juplo/endless-producer:1.0-SNAPSHOT + image: juplo/endless-long-producer:1.0-SNAPSHOT ports: - 8080:8080 environment: -- 2.20.1