3 if [ "$1" = "cleanup" ]
7 docker image rm juplo/jdbc:outbox
8 docker image rm juplo/outbox:polling
13 $(docker image ls -q juplo/jdbc:outbox) == "" ||
14 $(docker image ls -q juplo/outbox:polling) == "" ||
20 echo "Using image existing images:"
21 docker image ls juplo/jdbc:outbox
22 docker image ls juplo/outbox:polling
25 trap 'kill $(jobs -p)' EXIT
27 docker-compose up -d zookeeper kafka
29 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
31 echo "Waiting for kafka...";
35 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 3 --topic outbox
38 docker-compose up -d jdbc outbox kafkacat
40 while ! [[ $(http :8080/actuator/health 2>/dev/null | jq -r .status) == "UP" ]];
42 echo "Waiting for User-Service...";
47 docker-compose logs -f kafkacat &
51 echo peter$i | http :8080/users
52 echo uwe$i | http :8080/users
53 echo simone$i | http :8080/users
54 http DELETE :8080/users/franz$i
55 http DELETE :8080/users/simone$i
56 echo franz$i | http :8080/users
57 echo beate$i | http :8080/users
58 http DELETE :8080/users/uwe$i