From: Kai Moritz Date: Mon, 29 Aug 2022 16:59:29 +0000 (+0200) Subject: Vorführ-Skript überarbeitet: Vorgang durch andere Reihenfolge beschleunigt X-Git-Tag: sumup-adder--vorlage---lvm-2-tage~9 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=a8e18a7ca9cb26ec03cd3541ddc7b85d93c2a20c;p=demos%2Fkafka%2Ftraining Vorführ-Skript überarbeitet: Vorgang durch andere Reihenfolge beschleunigt * Dadurch das beide Consumer 1x ordentlich gestoppt werden, wird sowohl für `peter` als auch für `klaus` mal die Resultate in der Mongo-DB gespeichert. * Da dies zuvor nur für einen der Nutzer geschehen ist, hat das Skript nach dem außerordentlichen Beenden eines Consumer sehr lange warten müssen, bis nach dem Neustart die Verarbeitung der angelaufenen Daten so weit fortgeschritten war, dass erste Resultate für beide Consumer sichtbar geworden sind. --- diff --git a/README.sh b/README.sh index 3f74cd1..d22179d 100755 --- a/README.sh +++ b/README.sh @@ -74,20 +74,20 @@ http :8092/results/peter | jq .[].sum | uniq echo "Resultate für klaus von adder-2" http :8092/results/klaus | jq .[].sum | uniq -docker-compose stop adder-2 -until [ $(http --check-status :8091/results/peter 2> /dev/null) ]; do echo "Waiting for some results for peter to show up on adder-1..."; sleep 1; done -until [ $(http --check-status :8091/results/klaus 2> /dev/null) ]; do echo "Waiting for some results for klaus to show up on adder-1..."; sleep 1; done +docker-compose stop adder-1 +until [ $(http --check-status :8092/results/peter 2> /dev/null) ]; do echo "Waiting for some results for peter to show up on adder-2..."; sleep 1; done +until [ $(http --check-status :8092/results/klaus 2> /dev/null) ]; do echo "Waiting for some results for klaus to show up on adder-2..."; sleep 1; done -echo "Resultate für adder-1" -http -v --pretty none -S :8091/results +echo "Resultate für adder-2" +http -v --pretty none -S :8092/results echo -echo "Resultate für peter von adder-1" -http :8091/results/peter | jq .[].sum | uniq -echo "Resultate für klaus von adder-1" -http :8091/results/klaus | jq .[].sum | uniq +echo "Resultate für peter von adder-2" +http :8092/results/peter | jq .[].sum | uniq +echo "Resultate für klaus von adder-2" +http :8092/results/klaus | jq .[].sum | uniq -docker-compose kill -s 9 adder-1 +docker-compose kill -s 9 adder-2 docker-compose start adder-1 while ! [[ $(http 0:8091/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder-1..."; sleep 1; done until [ $(http --check-status :8091/results/peter 2> /dev/null) ]; do echo "Waiting for some results for peter to show up on adder-1..."; sleep 1; done