X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=ddf55faa8a7e1ab070b1cfd724def9395225dca6;hb=253b29d99f9aa8edabc5fcd28f6fe28644b18b2c;hp=0ee50a95bc364a4b808edb6947faa77a1966a0cf;hpb=aede797f2987de8c4c9c7630ce9ef73836044770;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 0ee50a9..ddf55fa 100755 --- a/README.sh +++ b/README.sh @@ -2,7 +2,7 @@ if [ "$1" = "cleanup" ] then - docker-compose 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 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 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