X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=10e79a07da45a5dbf718709824c17cd33a071efc;hb=bbf5810e5bd73f9dda532b2526e8442521f4f5d1;hp=270dfa8213959247cd7fda36d9254998326be880;hpb=e7dee76bfcdcac440352a226409ab9047275aa72;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 270dfa8..10e79a0 100755 --- a/README.sh +++ b/README.sh @@ -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,6 +24,11 @@ else fi docker-compose up setup -docker-compose up 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 up -d acks-all acks-1 +sleep 5 +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