X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=7d6406d95e6e78c4615c18b855f3631e6b7684ea;hb=47d30fd1c2d1f9c2afe11e12a422d4c69300a0c2;hp=8dcc24c7a5d0b216f5db9205e70dca6f83fb5081;hpb=107010572c028dcacf7115b6f90e6afc63be00f8;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 8dcc24c..7d6406d 100755 --- a/README.sh +++ b/README.sh @@ -2,13 +2,31 @@ if [ "$1" = "cleanup" ] then - docker-compose down -v + docker-compose -f docker/docker-compose.yml down -t0 -v --remove-orphans exit fi -trap 'kill $(jobs -p) 2>/dev/null' EXIT +docker-compose -f docker/docker-compose.yml up --remove-orphans setup || exit 1 +docker-compose -f docker/docker-compose.yml ps -docker-compose up -d +docker-compose -f docker/docker-compose.yml up -t0 -d cli +sleep 1 +docker-compose -f docker/docker-compose.yml logs setup -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 +echo +echo "Hilfe-Ausgabe von kafkacat" +echo +docker-compose -f docker/docker-compose.yml exec -T cli kafkacat -h +echo +echo "Nachrichten schreiben mit kafkacat" +echo +docker-compose -f docker/docker-compose.yml exec -T cli kafkacat -P -b kafka:9092 -t test << EOF +Hallo Welt! +Nachricht #1 +Nachricht #2 +Nachricht #3 +EOF +echo +echo "Nachrichten lesen mit kafkacat" +echo +docker-compose -f docker/docker-compose.yml exec cli kafkacat -C -b kafka:9092 -t test -o beginning -e