X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=e7721440193078709072974088eafa6d7d4ea4c4;hb=a22627477d23328b168e06cac2a807db1f1145f2;hp=53b42e9bc5ac59d6b3c342b487272d52f7452481;hpb=620191782035383e0083dc348e4941c9cec0d994;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 53b42e9..e772144 100755 --- a/README.sh +++ b/README.sh @@ -1,6 +1,6 @@ #!/bin/bash -IMAGE=juplo/endless-consumer:1.0-SNAPSHOT +IMAGE=juplo/sumup-adder:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then @@ -9,14 +9,17 @@ then exit fi -docker-compose up -d zookeeper kafka cli +docker-compose stop adder +docker-compose rm -svf mongo +docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli mongo express if [[ $(docker image ls -q $IMAGE) == "" || "$1" = "build" ]] then - mvn install || exit + docker-compose rm -svf adder + mvn -D skipTests clean install || exit else echo "Using image existing images:" docker image ls $IMAGE @@ -25,16 +28,23 @@ 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 peter beate +docker-compose up -d gateway requests adder -sleep 15 +while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for gateway..."; sleep 1; done +while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for requests..."; sleep 1; done +while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder..."; sleep 1; done -http -v post :8082/stop -sleep 10 -docker-compose kill -s 9 peter -http -v post :8082/start -sleep 60 +docker-compose up -d peter + +while [[ "$(http :8082/results | jq -r .)" == "{}" ]]; do echo "Waiting for some results to show up..."; done +http -v :8082/results +sleep 3 +http -v :8082/results +http :8082/results/peter | jq .[].sum | uniq +docker-compose kill -s 9 adder -docker-compose stop producer peter beate -docker-compose logs beate -docker-compose logs --tail=10 peter +docker-compose up -d adder +docker-compose kill -s 9 peter +while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder..."; sleep 1; done +while [[ "$(http :8082/results | jq -r .)" == "{}" ]]; do echo "Waiting for some results to show up..."; sleep 1; done +http :8082/results/peter | jq .[].sum | uniq