3 if [ "$1" = "cleanup" ]
7 docker image rm juplo/data-jdbc:polling-outbox-2
8 docker image rm juplo/outbox-delivery:polling-outbox-3-SNAPSHOT
12 docker-compose up -d zookeeper kafka
15 $(docker image ls -q juplo/data-jdbc:polling-outbox-2) == "" ||
16 $(docker image ls -q juplo/outbox-delivery:polling-outbox-3-SNAPSHOT) == "" ||
22 echo "Using image existing images:"
23 docker image ls juplo/data-jdbc:polling-outbox-2
24 docker image ls juplo/outbox-delivery:polling-outbox-3-SNAPSHOT
27 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
29 echo "Waiting for kafka...";
33 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 3 --topic outbox
36 docker-compose up -d jdbc outbox kafkacat
38 while ! [[ $(http :8080/actuator/health 2>/dev/null | jq -r .status) == "UP" ]];
40 echo "Waiting for User-Service...";
45 docker-compose logs --tail=0 -f jdbc kafkacat &
49 echo peter$i | http :8080/users
50 echo uwe$i | http :8080/users
51 echo peter$i | http :8080/users
52 echo simone$i | http :8080/users
53 echo beate$i | http :8080/users
54 http DELETE :8080/users/franz$i
55 http DELETE :8080/users/simone$i
56 echo beate$i | http :8080/users
57 http DELETE :8080/users/beate$i
58 echo franz$i | http :8080/users
59 echo franz$i | http :8080/users
60 echo beate$i | http :8080/users
61 http DELETE :8080/users/uwe$i
64 docker-compose exec postgres psql -Uoutbox -c'SELECT * FROM outbox;' -Ppager=0 outbox
65 docker-compose logs kafkacat | grep peter
66 # "kill" the executions of "docker-compose logs ..."
67 docker-compose stop jdbc kafkacat