Synchronisation bei Start/Stop repariert und Ausgabe für Fehler ergänzt
[demos/kafka/training] / README.sh
1 #!/bin/bash
2
3 IMAGE=juplo/endless-producer:1.0-SNAPSHOT
4
5 if [ "$1" = "cleanup" ]
6 then
7   docker-compose down -v
8   mvn clean
9   exit
10 fi
11
12 docker-compose up -d zookeeper kafka cli
13
14 if [[
15   $(docker image ls -q $IMAGE) == "" ||
16   "$1" = "build"
17 ]]
18 then
19   mvn install || exit
20 else
21   echo "Using image existing images:"
22   docker image ls $IMAGE
23 fi
24
25 echo "Waiting for the Kafka-Cluster to become ready..."
26 docker-compose exec kafka cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
27 docker-compose up setup
28 docker-compose up -d producer
29 sleep 5
30 docker-compose stop producer
31 docker-compose logs producer