X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=4a98289d909dc0f9cf8892d646e84cd142d6652c;hb=903c5f85e92ac1ae6d47c006ec13b162994eb329;hp=30d4be23fb0cdd168f4a6b611a7adb232bed707b;hpb=96a8aea01a81e47f163170779dc7168b2d51a9f1;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 30d4be2..4a98289 100755 --- a/README.sh +++ b/README.sh @@ -1,10 +1,10 @@ #!/bin/bash -IMAGE=juplo/simple-producer:1.0-SNAPSHOT +IMAGE=juplo/supersimple-producer:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then - docker-compose down -v + docker-compose down -v --remove-orphans mvn clean exit fi @@ -24,11 +24,7 @@ else fi docker-compose up setup -docker-compose up -d producer -sleep 5 +docker-compose ps +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 +docker-compose exec cli kafkacat -b kafka:9092 -t test -e -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n'