X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=3bc7e8a3a27dc40ff04fc1424d515ba41ea120fc;hb=a867af892dcc4978bb8f6b55996f822f63875b79;hp=8a9f790788c53e0f1d8f6c130ae79af085588c6d;hpb=510d12cfdbfa4fac3914b271894d6db3451eb8ee;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 8a9f790..3bc7e8a 100755 --- a/README.sh +++ b/README.sh @@ -29,41 +29,29 @@ docker-compose up -d while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-1..."; sleep 1; done while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-all..."; sleep 1; done -kafkacat -L -b :9092 -docker-compose exec cli kafka-topics --bootstrap-server kafka:9092 --describe --topic test # tag::foo[] echo foo | http -v :8081/acks-1 echo foo | http -v :8082/acks-all kafkacat -C -b :9092 -t test -o 0 -e -f'p=%p|o=%o|k=%k|v=%s\n' # end::foo[] -sleep 1 -kafkacat -L -b :9092 -docker-compose exec cli kafka-topics --bootstrap-server kafka:9092 --describe --topic test -kafkacat -C -b :9092 -t test -o 0 -e -f'p=%p|o=%o|k=%k|v=%s\n' # tag::stop[] docker-compose stop kafka-1 -kafkacat -L -b :9092 -# end::stop[] docker-compose exec cli kafka-topics --bootstrap-server kafka:9092 --describe --topic test +# end::stop[] time echo bar | http -v :8081/acks-1 time echo bar | http -v :8081/acks-1 time echo bar | http -v :8082/acks-all time echo bar | http -v :8082/acks-all sleep 1 -kafkacat -L -b :9092 -docker-compose exec cli kafka-topics --bootstrap-server kafka:9092 --describe --topic test kafkacat -C -b :9092 -t test -o 0 -e -f'p=%p|o=%o|k=%k|v=%s\n' docker-compose stop kafka-3 -kafkacat -L -b :9092 docker-compose exec cli kafka-topics --bootstrap-server kafka:9092 --describe --topic test time echo foobar | http -v :8081/acks-1 time echo foobar | http -v :8081/acks-1 time echo foobar | http -v :8082/acks-all sleep 1 -kafkacat -L -b :9092 -docker-compose exec cli kafka-topics --bootstrap-server kafka:9092 --describe --topic test kafkacat -C -b :9092 -t test -o 0 -e -f'p=%p|o=%o|k=%k|v=%s\n'