X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=a60804ae86fef622898997bcc69a95af056f2139;hb=1437f0138472baefe3811ded7d3b1085845bb28e;hp=8b568c9537e2f6086e44052c1d18447bdb928339;hpb=50da4f6f74a8f4f567b7af8556480f81256c61dc;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 8b568c9..a60804a 100755 --- a/README.sh +++ b/README.sh @@ -9,7 +9,7 @@ then exit fi -docker-compose up -d zookeeper kafka cli +docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli if [[ $(docker image ls -q $IMAGE) == "" || @@ -23,77 +23,20 @@ else 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 exec cli cub kafka-ready -b kafka:9092 3 60 > /dev/null 2>&1 || exit 1 docker-compose up setup - docker-compose up -d sleep 15 -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen - -http post :8081/stop -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen - -http post :8081/start - -sleep 1 -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen -sleep 1 -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen -sleep 1 -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen -sleep 1 -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen -sleep 1 -http :8081/status -http :8082/status -http :8083/status -http :8084/status -http :8085/status -http :8000/seen -http post :8081/stop -http :8081/status -http post :8082/stop -http :8082/status -http post :8083/stop -http :8083/status -http post :8084/stop -http :8084/status -http post :8085/stop -http :8085/status +echo foo | http -v :8080/foo +docker-compose kill -s 9 kafka-1 +sleep 5 +echo bar | http -v :8080/bar +docker-compose kill -s 9 kafka-3 +sleep 5 +echo foobar | http -v :8080/foobar -http :8000/seen -http post :8000/stop +http -v :8081/seen -docker-compose logs producer +docker-compose stop producer consumer