X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=10e79a07da45a5dbf718709824c17cd33a071efc;hb=bbf5810e5bd73f9dda532b2526e8442521f4f5d1;hp=30d4be23fb0cdd168f4a6b611a7adb232bed707b;hpb=96a8aea01a81e47f163170779dc7168b2d51a9f1;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 30d4be2..10e79a0 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 @@ -10,7 +10,7 @@ then fi docker-compose up -d kafka-1 kafka-2 kafka-3 cli -docker-compose rm -svf producer +docker-compose rm -svf acks-all acks-1 acks-0 if [[ $(docker image ls -q $IMAGE) == "" || @@ -24,11 +24,11 @@ else fi docker-compose up setup -docker-compose up -d producer +docker-compose up -d acks-all acks-1 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 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 +docker-compose stop kafka-1 +sleep 5 +docker-compose stop kafka-3 +sleep 5 +docker-compose stop acks-all acks-1 +docker-compose logs acks-all acks-1