X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fdeduplication;a=blobdiff_plain;f=README.sh;h=dcd632a7f213bbb0c38163b9651c27979cf81487;hp=00383c44ed72413f3d89d733cc1d6876edc2001d;hb=a84868373c1803dca9f6203085240b107af44257;hpb=29eac6d5ee3ab76af19edef6d8863c6894313169 diff --git a/README.sh b/README.sh index 00383c4..dcd632a 100755 --- a/README.sh +++ b/README.sh @@ -4,6 +4,7 @@ if [ "$1" = "cleanup" ] then docker-compose down mvn clean + rm *.txt exit fi @@ -18,6 +19,11 @@ fi docker-compose up -d zookeeper kafka +if [ ! -e data.txt ]; +then + echo ./create-data.sh +fi + while ! [[ $(zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]]; do echo "Waiting for kafka...";