3 if [ "$1" = "cleanup" ]
5 docker-compose -f docker/docker-compose.yml down -t0 -v --remove-orphans
9 docker-compose -f docker/docker-compose.yml up -d --remove-orphans kafka-1 kafka-2 kafka-3
11 echo "Waiting for the Kafka-Cluster to become ready..."
12 docker-compose -f docker/docker-compose.yml run --rm cli cub kafka-ready -b kafka:9092 3 60 > /dev/null 2>&1 || exit 1
14 docker-compose -f docker/docker-compose.yml up -t0 -d cli
16 docker-compose -f docker/docker-compose.yml up -d acks-0 acks-1 acks-all
17 while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-0..."; sleep 1; done
18 while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-1..."; sleep 1; done
19 while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-all..."; sleep 1; done
21 echo "Resetting the topic"
22 docker-compose -f docker/docker-compose.yml restart setup
24 echo -n Alle Broker laufen über acks-0 | http -v :8080/foo
25 echo -n Alle Broker laufen über acks-1 | http -v :8081/foo
26 echo -n Alle Broker laufen über acks-all | http -v :8082/foo
28 echo "Stopping kafka-1"
29 docker-compose -f docker/docker-compose.yml stop kafka-1
30 echo "Restarting acks-0 acks-1 acks-all"
31 docker-compose -f docker/docker-compose.yml restart acks-0 acks-1 acks-all
32 while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-0..."; sleep 1; done
33 while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-1..."; sleep 1; done
34 while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-all..."; sleep 1; done
36 echo -n kafka-1 wurde beendet über acks-0 | http -v :8080/foo
37 echo -n kafka-1 wurde beendet über acks-1 | http -v :8081/foo
38 echo -n kafka-1 wurde beendet über acks-all | http -v :8082/foo
40 echo "Stopping kafka-3"
41 docker-compose -f docker/docker-compose.yml stop kafka-3
42 echo "Restarting acks-0 acks-1 acks-all"
43 docker-compose -f docker/docker-compose.yml restart acks-0 acks-1 acks-all
44 while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-0..."; sleep 1; done
45 while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-1..."; sleep 1; done
46 while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for acks-all..."; sleep 1; done
48 echo -n kafka-1 und kafka-3 wurden beendet über acks-0 | http -v :8080/foo
49 echo -n kafka-1 und kafka-3 wurden beendet über acks-1 | http -v :8081/foo
50 echo -n kafka-1 und kafka-3 wurden beendet über acks-all | http -v :8082/foo
52 echo "Reading all messages, that were really written:"
53 kafkacat -b :9092 -t test -o 0 -f'key: %k\toffset: %o\tvalue: %s\n' -qe