X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;fp=README.sh;h=dcd632a7f213bbb0c38163b9651c27979cf81487;hb=eada2e8eb27b2cff46a1cb87dfa5817dab008e0d;hp=00383c44ed72413f3d89d733cc1d6876edc2001d;hpb=e1bd976486d1d1a087567a6c6081637d48706f44;p=demos%2Fkafka%2Fdeduplication 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...";