X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=270dfa8213959247cd7fda36d9254998326be880;hb=d53fff8f9365e1f49278bc312e12930c04546ca0;hp=30d4be23fb0cdd168f4a6b611a7adb232bed707b;hpb=96a8aea01a81e47f163170779dc7168b2d51a9f1;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 30d4be2..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 @@ -24,11 +24,6 @@ else fi docker-compose up setup -docker-compose up -d producer -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