X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=1394020a4f89cd9410fcd7e347c85d27d29314b1;hb=1e858c1835d47259583cf3cce18921c550682e2b;hp=e7721440193078709072974088eafa6d7d4ea4c4;hpb=a22627477d23328b168e06cac2a807db1f1145f2;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index e772144..1394020 100755 --- a/README.sh +++ b/README.sh @@ -1,6 +1,6 @@ #!/bin/bash -IMAGE=juplo/sumup-adder:1.0-SNAPSHOT +IMAGE=juplo/spring-consumer:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then @@ -9,17 +9,16 @@ then exit fi -docker-compose stop adder -docker-compose rm -svf mongo -docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli mongo express +trap 'kill $(jobs -p) 2>/dev/null' EXIT + +docker-compose up -d kafka-0 kafka-1 kafka-2 kafka-3 cli if [[ $(docker image ls -q $IMAGE) == "" || "$1" = "build" ]] then - docker-compose rm -svf adder - mvn -D skipTests clean install || exit + mvn clean install || exit else echo "Using image existing images:" docker image ls $IMAGE @@ -28,23 +27,12 @@ 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 gateway requests adder - -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 - -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 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 +docker-compose up -d producer + +mvn spring-boot:run & +sleep 10 +kill $(jobs -p) +mvn spring-boot:run & +sleep 10 +docker-compose stop producer +kill $(jobs -p)