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'