X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;fp=README.sh;h=ddf55faa8a7e1ab070b1cfd724def9395225dca6;hb=2e829aa88ce1dc203d2daad12140e5eb95794f1a;hp=7ddfbbf5219e9a6928efe3b2447371a368a53838;hpb=ee5042122da662e570fdf234bb794f91ab891863;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 7ddfbbf..ddf55fa 100755 --- a/README.sh +++ b/README.sh @@ -2,7 +2,7 @@ if [ "$1" = "cleanup" ] then - docker-compose -f docker/docker-compose.yml down -v + docker-compose -f docker/docker-compose.yml down -t0 -v --remove-orphans mvn clean exit fi @@ -12,20 +12,27 @@ if [ "$1" = "build" ]; then exit; fi trap 'kill $(jobs -p) 2>/dev/null' EXIT -docker-compose -f docker/docker-compose.yml up -d - +docker-compose -f docker/docker-compose.yml up -d kafka-1 kafka-2 kafka-3 +docker-compose -f docker/docker-compose.yml ps echo "Waiting for the Kafka-Cluster to become ready..." -docker-compose -f docker/docker-compose.yml exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1 +docker-compose -f docker/docker-compose.yml run --rm cli cub kafka-ready -b kafka:9092 3 60 > /dev/null 2>&1 || exit 1 + +docker-compose -f docker/docker-compose.yml up -t0 -d cli +sleep 1 +docker-compose -f docker/docker-compose.yml logs setup +echo echo "Producing messages" mvn exec:java@producer +echo echo "Reading messages" mvn exec:java@consumer & sleep 7 kill $(jobs -p) sleep 2 +echo echo "Re-Reading messages" mvn exec:java@consumer & sleep 7