3 if [ "$1" = "cleanup" ]
7 docker image rm juplo/seek:1.0-SNAPSHOT
11 docker-compose up -d zookeeper kafka
14 $(docker image ls -q juplo/seek:1.0-SNAPSHOT) == "" ||
20 echo "Using image existing images:"
21 docker image ls juplo/seek:1.0-SNAPSHOT
24 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
26 echo "Waiting for kafka...";
30 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
32 docker-compose up -d producer
33 docker-compose up -d perter franz beate ute klaus paul sigi
35 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
37 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
39 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
41 docker-compose stop producer franz beate ute klaus paul sigi
42 docker-compose logs consumer