From: Kai Moritz <kai@juplo.de>
Date: Fri, 12 Aug 2022 20:31:24 +0000 (+0200)
Subject: Compose-Setup und README.sh für dieses Beispiel repariert
X-Git-Tag: endless-stream-consumer-DEPRECATED^2^2^2~1^2~2^2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=d6285c99580cf17465182b68c68ae9a3674ae7a7;p=demos%2Fkafka%2Ftraining

Compose-Setup und README.sh für dieses Beispiel repariert

* 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.
---

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: