3 # Führt so noch nix sinnvolles vor!
4 # Skript passt nicht zu Implementierung.
5 # Implementierung macht (noch?) keinen Sinn.
7 if [ "$1" = "cleanup" ]
11 docker image rm juplo/seek:1.0-SNAPSHOT
15 docker-compose up -d zookeeper kafka
18 $(docker image ls -q juplo/seek:1.0-SNAPSHOT) == "" ||
24 echo "Using image existing images:"
25 docker image ls juplo/seek:1.0-SNAPSHOT
28 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
30 echo "Waiting for kafka...";
34 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
36 docker-compose up -d producer
37 docker-compose up -d peter franz beate ute klaus paul siggi
39 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
41 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
43 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
45 docker-compose stop producer franz beate ute klaus paul sigi
46 docker-compose logs consumer