X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=01d6d00032f5fc78f8f6767342236863f57e7c07;hb=bc8304e07ecbb240fcd02e26a7387006e58c3c42;hp=b1ba0be493e6efe4d6d6a1ed7830f823262e2450;hpb=4c4eaa9bf0d40ca631ac78d3a51c36cfcda4fe6f;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index b1ba0be..01d6d00 100755 --- a/README.sh +++ b/README.sh @@ -9,14 +9,16 @@ then exit fi -docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli +trap 'kill $(jobs -p) 2>/dev/null' EXIT + +docker-compose up -d kafka-0 kafka-1 kafka-2 kafka-3 cli if [[ $(docker image ls -q $IMAGE) == "" || "$1" = "build" ]] then - mvn install || exit + mvn clean install || exit else echo "Using image existing images:" docker image ls $IMAGE @@ -25,12 +27,12 @@ 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 -sleep 5 - -docker-compose exec cli kafkacat -b kafka:9092 -t test -q -c 20 -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n' +docker-compose up -d producer -docker-compose stop producer consumer-1 consumer-2 consumer-3 -docker-compose logs consumer-1 -docker-compose logs consumer-2 -docker-compose logs consumer-3 +mvn spring-boot:run & +sleep 10 +kill $(jobs -p) +mvn spring-boot:run & +sleep 10 +docker-compose stop producer +kill $(jobs -p)