X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=7cae320200d54be2d2b947978cf5ab9d75c42ac1;hb=0e80eb6e012efd62ec0a9f7313d1311a934dded1;hp=0daad7458fcfc1052aa4227087aba234cc3da2cc;hpb=5578cfee8c646f4a5c2d30388c3895b4dbbb306f;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 0daad74..7cae320 100755 --- a/README.sh +++ b/README.sh @@ -4,12 +4,12 @@ IMAGE=juplo/simple-producer:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then - docker-compose down -v + docker-compose down -v --remove-orphans mvn clean exit fi -docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli +docker-compose up -d kafka-1 kafka-2 kafka-3 cli docker-compose rm -svf producer if [[ @@ -23,10 +23,9 @@ else docker image ls $IMAGE 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 +docker-compose ps +docker-compose up -d producer 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'