X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fseek;a=blobdiff_plain;f=README.sh;fp=README.sh;h=09b1ba507a3414f2661e4462f8437d20d099daa1;hp=16f8af50680128f1a3cda8a1d21a7df8cd094286;hb=d6b305a86f7006eb52be48a9f233352523437e6d;hpb=206e7920ca828fd52c9d93671ef3d222239c455f

diff --git a/README.sh b/README.sh
index 16f8af5..09b1ba5 100755
--- a/README.sh
+++ b/README.sh
@@ -1,8 +1,4 @@
 #!/bin/bash
-#
-# Führt so noch nix sinnvolles vor!
-# Skript passt nicht zu Implementierung.
-# Implementierung macht (noch?) keinen Sinn.
 
 if [ "$1" = "cleanup" ]
 then
@@ -25,22 +21,25 @@ else
   docker image ls juplo/seek:1.0-SNAPSHOT
 fi
 
-while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
-do
-  echo "Waiting for kafka...";
-  sleep 1;
-done
+docker-compose up -d peter franz
+echo "Waiting for the Kafka-Cluster to become ready..."
+docker-compose exec kafka cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
 
 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
 
 docker-compose up -d producer
-docker-compose up -d peter franz beate ute klaus paul siggi
+
+sleep 3
+http -v post :8001/start
 sleep 3
-docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest 
+echo 0 | http -v :8001/seek
 sleep 3
-docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest 
+echo 0 | http -v :8001/seek
+
+http -v post :8002/start
+sleep 10
+echo 0 | http -v :8001/seek
 sleep 3
-docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest 
 
-docker-compose stop producer franz beate ute klaus paul sigi
-docker-compose logs consumer
+docker-compose stop producer peter franz
+docker-compose logs peter