X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=05178a3403379e5f3615e298b1da19007e24095e;hb=d2eb370acf1a2195c36421ffc471f67cb4a8e86e;hp=0ee50a95bc364a4b808edb6947faa77a1966a0cf;hpb=aede797f2987de8c4c9c7630ce9ef73836044770;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 0ee50a9..05178a3 100755 --- a/README.sh +++ b/README.sh @@ -1,5 +1,7 @@ #!/bin/bash +IMAGE=juplo/sumup-adder:1.0-SNAPSHOT + if [ "$1" = "cleanup" ] then docker-compose down -v @@ -7,27 +9,38 @@ then exit fi -mvn package || exit 1 -if [ "$1" = "build" ]; then exit; fi - -trap 'kill $(jobs -p) 2>/dev/null' EXIT +docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli mongo express -docker-compose up -d +if [[ + $(docker image ls -q $IMAGE) == "" || + "$1" = "build" +]] +then + docker-compose rm -svf adder + mvn clean install || exit +else + echo "Using image existing images:" + docker image ls $IMAGE +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 ute franz beate klaus uschi -echo "Producing messages" -mvn exec:java@producer +http -v :8082/results +sleep 3 +http -v :8082/results -echo "Reading messages" -mvn exec:java@consumer & -sleep 7 -kill $(jobs -p) -sleep 2 +docker-compose kill -s 9 adder -echo "Re-Reading messages" -mvn exec:java@consumer & -sleep 7 -kill $(jobs -p) -sleep 2 +docker-compose up -d adder +sleep 3 +docker-compose kill -s 9 peter ute franz beate klaus uschi +http -v :8082/results