X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=4f7f0174b3017808dfa613ec453e81c42601adfc;hb=b731ace5dfbcf51f996dea631106d53f7ac85d73;hp=9bca15056024ef2b04d4cf5d81d20fdf8c7e12fa;hpb=547be767ea719e47c7f59a2fe86bc2b6aa148741;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 9bca150..4f7f017 100755 --- a/README.sh +++ b/README.sh @@ -26,12 +26,12 @@ 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 up setup docker-compose up -d - -sleep 15 - -echo foo | http :8080/bar -dd if=/dev/zero bs=1024 count=1024 | http :8080/fehler -http :8081/seen - -docker-compose stop producer consumer -docker-compose logs producer +while ! [[ $(http -b :8080/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for :8080/actuator/health; sleep 1; done + +# tag::http[] +echo -n bar | http -v :8080/foo +echo -n foo | http -v :8080/bar X-id:666 +# end::http[] +# tag::kafkacat[] +docker-compose exec cli kafkacat -b kafka:9092 -t test -f "%p|%o|%k=%s|%h\n" -e +# end::kafkacat[]