X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=7bcc99623271839aa1cf83ecc0dbaf5230a1db81;hb=0a23b208086aa3617f75d48e4e1b286cfdf9e64d;hp=d0dc7ea09dfee397650faeae507579f519e75eb7;hpb=bbe065afd24ed02fca10986c9a09823f7f6278a2;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index d0dc7ea..7bcc996 100755 --- a/README.sh +++ b/README.sh @@ -1,6 +1,6 @@ #!/bin/bash -IMAGE=juplo/spring-consumer-json:1.0-SNAPSHOT +IMAGE=juplo/spring-consumer--json:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then @@ -34,19 +34,13 @@ while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Wait while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for consumer-1..."; sleep 1; done while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for consumer-2..."; sleep 1; done -# tag::nachrichten[] echo 6 | http -v :8080/peter echo 77 | http -v :8080/klaus -# end::nachrichten[] -echo "Writing poison pill..." -# tag::poisonpill[] -echo 'BOOM!' | kafkacat -P -b :9092 -t test -# end::poisonpill[] +echo "Writing logic error..." +echo 66 | http -v :8080/peter?error=1 +echo 7 | http -v :8080/klaus +sleep 5 +docker-compose -f docker/docker-compose.yml stop consumer-1 consumer-2 docker-compose -f docker/docker-compose.yml logs -f consumer-1 consumer-2 - -echo "Restarting consumer-1..." -# tag::restart[] -docker-compose -f docker/docker-compose.yml up consumer-1 -# end::restart[]