X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;fp=README.sh;h=1b4d2179f2bea04aa2d1bd32345cdbe6190818a6;hb=a7e838d24e71a23fe2ee6611e6581d4ccce119bd;hp=76ed9c3c85a5d9e72881055d5ff1cc9b01fe0ac2;hpb=061fcde1c8d74912149dfbbd7b19d311d9f29718;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 76ed9c3..1b4d217 100755 --- a/README.sh +++ b/README.sh @@ -29,10 +29,8 @@ while ! [[ $(http 0:8000/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Wait while ! [[ $(http 0:8001/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for producer-1..."; sleep 1; done docker-compose up -d consumer -# tag::http[] echo -n Nachricht 1 an Producer 0 | http -v :8000/foo echo -n Nachricht 1 an Producer 1 | http -v :8001/foo -# end::http[] echo -n Nachricht 2 an Producer 0 | http -v :8000/bar echo -n Nachricht 2 an Producer 1 | http -v :8001/bar @@ -41,9 +39,7 @@ docker-compose logs consumer docker-compose exec -T cli bash << 'EOF' echo "Altering number of partitions from 3 to 7..." kafka-topics --bootstrap-server kafka:9092 --describe --topic test -# tag::repartitioning[] kafka-topics --bootstrap-server kafka:9092 --alter --topic test --partitions 7 -# end::repartitioning[] kafka-topics --bootstrap-server kafka:9092 --describe --topic test EOF @@ -58,7 +54,5 @@ echo -n Nachricht 4 an Producer 1 | http -v :8001/bar docker-compose logs consumer -# tag::kafkacat[] kafkacat -b :9092 -t test -o 0 -p0 -f'p=%p|o=%o|k=%k|v=%s\n' -qe kafkacat -b :9092 -t test -o 0 -p1 -f'p=%p|o=%o|k=%k|v=%s\n' -qe -# end::kafkacat[]