X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=270dfa8213959247cd7fda36d9254998326be880;hb=0cf4b667026edf0587cc7a8c9698a025e112b600;hp=0daad7458fcfc1052aa4227087aba234cc3da2cc;hpb=5578cfee8c646f4a5c2d30388c3895b4dbbb306f;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 0daad74..270dfa8 100755 --- a/README.sh +++ b/README.sh @@ -1,6 +1,6 @@ #!/bin/bash -IMAGE=juplo/simple-producer:1.0-SNAPSHOT +IMAGE=juplo/supersimple-producer:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then @@ -9,7 +9,7 @@ then 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,14 +23,7 @@ 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 -sleep 5 +docker-compose up producer -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 stop producer docker-compose exec cli kafkacat -b kafka:9092 -t test -q -e -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n' -docker-compose logs producer