X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=20c873ea29a3faaf1ff785fe27283273fc5e663b;hb=refs%2Ftags%2Fspring-consumer--kafkalistener---lvm-2-tage--easy-path;hp=e8039741e635f5c46b5e33dd8a03abb43eba2c75;hpb=06b366bc4a98699288b6e890cc257b1fed4797ef;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index e803974..20c873e 100755 --- a/README.sh +++ b/README.sh @@ -1,15 +1,15 @@ #!/bin/bash -IMAGE=juplo/simple-consumer:1.0-SNAPSHOT +IMAGE=juplo/spring-consumer-kafkalistener:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then - docker-compose down -v + docker-compose down -v --remove-orphans mvn clean exit fi -docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli +docker-compose up -d kafka-1 kafka-2 kafka-3 cli docker-compose rm -svf consumer if [[ @@ -23,21 +23,16 @@ else docker image ls $IMAGE fi -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 +docker-compose up -d producer +docker-compose ps +docker-compose up -d consumer sleep 5 +docker-compose stop consumer -docker-compose restart consumer - +docker-compose start consumer sleep 5 -docker-compose stop consumer producer +docker-compose stop producer consumer docker-compose logs consumer - -echo "Received messages for test/0" -docker-compose logs consumer | grep test/0 -echo "Received messages for test/1" -docker-compose logs consumer | grep test/1