X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=1a3efb2bd8aa37306a5723401b52ff81d5918af6;hb=cbf1b641e147552fdbafb1b440a5aab59dfe275f;hp=db1dde9eb5785765053f1ccae5d8078f3a911097;hpb=37fb7bb944bd5ef97493314091f043b4c801e6bc;p=demos%2Fkafka%2Fwordcount diff --git a/README.sh b/README.sh index db1dde9..1a3efb2 100755 --- a/README.sh +++ b/README.sh @@ -10,7 +10,7 @@ QUERY=juplo/wordcount--query:1.0.4 if [ "$1" = "cleanup" ] then - docker-compose down -v --remove-orphans + docker compose down -v --remove-orphans docker image rm $FORTUNE docker image rm $RECORDER docker image rm $USERS @@ -33,7 +33,7 @@ if [[ ]] then mvn clean package || exit - docker-compose rm -svf recorder users splitter counter top10 query + docker compose rm -svf recorder users splitter counter top10 query ( cd fortune; ./README.sh $FORTUNE; ) mvn -f recorder/pom.xml docker:build mvn -f users/pom.xml docker:build @@ -53,20 +53,24 @@ else fi -docker-compose up -d zookeeper kafka cli traefik +docker compose up setup -echo "Waiting for the Kafka-Cluster to become ready..." -docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1 -docker-compose exec cli zookeeper-shell zookeeper:2181 ls /brokers/ids - -docker-compose up -d users +echo "Starting the service 'users'..." +docker compose up -d users while [ "$(http users.localhost/actuator/health 2> /dev/null | jq -r .status 2> /dev/null)" != "UP" ]; do echo "Waiting for service users..."; sleep 1; done http -v post users.localhost username=bart firstName=Bart lastName=Simpson sex=MALE http -v post users.localhost username=nerd firstName=Jane lastName=Doe sex=FEMALE http -v post users.localhost username=riddler firstName=Rumpel lastName=Stilzchen sex=MALE -echo "Starting all instances..." -docker-compose up -d +echo "Starting the other instances..." +docker compose up -d recorder +docker compose up -d splitter +docker compose up -d counter +docker compose up -d top10 +docker compose up -d query + +echo "Starting the simulated users..." +docker compose up -d bart nerd riddler while [ "$(http query.localhost/actuator/health 2>/dev/null | jq -r .status 2> /dev/null)" != "UP" ]; do echo "Waiting for service query..."; sleep 1; done http -v query.localhost/bart @@ -85,7 +89,7 @@ http -v query.localhost/bart http -v query.localhost/nerd http -v query.localhost/riddler -docker-compose up -d --scale query=5 query +// docker compose up -d --scale query=5 query http -v --follow query.localhost/bart sleep 1 http -v --follow query.localhost/bart