X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=fbeb0f1079bde1be6fc5a3330121cfd79288ad53;hb=bb4f45a199dd0359d68f65e25ed809b64261f665;hp=0ee50a95bc364a4b808edb6947faa77a1966a0cf;hpb=aede797f2987de8c4c9c7630ce9ef73836044770;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 0ee50a9..fbeb0f1 100755 --- a/README.sh +++ b/README.sh @@ -3,31 +3,26 @@ if [ "$1" = "cleanup" ] then docker-compose down -v - mvn clean exit fi -mvn package || exit 1 -if [ "$1" = "build" ]; then exit; fi - -trap 'kill $(jobs -p) 2>/dev/null' EXIT - -docker-compose up -d +docker-compose up -d zookeeper kafka cli 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 - -echo "Producing messages" -mvn exec:java@producer - -echo "Reading messages" -mvn exec:java@consumer & -sleep 7 -kill $(jobs -p) +docker-compose up setup + +docker-compose up -d producer +docker-compose up -d peter +sleep 3 +docker-compose up -d franz +sleep 3 +docker-compose up -d beate +sleep 3 +docker-compose up -d klaus sleep 2 - -echo "Re-Reading messages" -mvn exec:java@consumer & -sleep 7 -kill $(jobs -p) +docker-compose stop franz sleep 2 +docker-compose kill -s 9 peter +sleep 5 +docker-compose stop producer peter franz beate klaus