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 ! [[ $(zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
31 echo "Waiting for kafka...";
35 kafka-topics --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 3 --topic outbox
38 docker-compose up -d jdbc outbox
40 while ! [[ $(http :8080/actuator/health 2>/dev/null | jq -r .status) == "UP" ]];
42 echo "Waiting for User-Service...";
47 kafkacat -C -b localhost:9092 -t outbox &
49 echo peter | http :8080/users
50 echo franz | http :8080/users
51 echo beate | http :8080/users
53 http DELETE :8080/users/franz