X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=ddf55faa8a7e1ab070b1cfd724def9395225dca6;hb=253b29d99f9aa8edabc5fcd28f6fe28644b18b2c;hp=95aae0b264ea7611224ed1dc3e13e7eef97a52f5;hpb=d4bf2b7400df95df6c3f2534519671e596163be2;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 95aae0b..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 kafka 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