3 IMAGE=juplo/rest-producer:1.0-SNAPSHOT
5 if [ "$1" = "cleanup" ]
12 docker-compose up -d kafka-0 kafka-1 kafka-2 kafka-3 cli
15 $(docker image ls -q $IMAGE) == "" ||
19 mvn clean install || exit
21 echo "Using image existing images:"
22 docker image ls $IMAGE
25 echo "Waiting for the Kafka-Cluster to become ready..."
26 docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
27 docker-compose up setup
28 docker-compose up -d producer-0 producer-1
29 while ! [[ $(http -b :8000/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for producer-0; sleep 1; done
30 while ! [[ $(http -b :8001/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for producer-1; sleep 1; done
31 docker-compose up -d consumer
33 echo foo | http -v :8000/foo
34 echo foo | http -v :8001/foo
35 echo foo | http -v :8001/foo
36 echo foo | http -v :8000/bar
37 echo foobar | http -v :8000/bar
38 echo foofoo | http -v :8000/bar
39 echo barbar | http -v :8000/bar
40 echo barfoo | http -v :8000/bar
41 echo bar | http -v :8000/bar
43 docker-compose logs consumer
46 docker-compose exec cli kafkacat -C -b kafka:9092 -t test -o 0 -f'p=%p|o=%o|k=%k|v=%s\n' -q -c20
48 docker-compose exec -T cli bash << 'EOF'
49 echo "Altering number of partitions from 3 to 7..."
50 kafka-topics --bootstrap-server kafka:9092 --describe --topic test
51 kafka-topics --bootstrap-server kafka:9092 --describe --topic test
52 kafka-topics --bootstrap-server kafka:9092 --alter --topic test --partitions 7
53 kafka-topics --bootstrap-server kafka:9092 --describe --topic test
56 docker-compose restart producer-0 producer-1
57 while ! [[ $(http -b :8000/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for :8000/actuator/health; sleep 1; done
58 while ! [[ $(http -b :8001/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for :8001/actuator/health; sleep 1; done
59 docker-compose exec cli kafkacat -C -b kafka:9092 -t test -o 0 -f'p=%p|o=%o|k=%k|v=%s\n' -q -c20
61 echo "Messages from peter"
62 docker-compose logs consumer | grep k=peter
63 echo "Messages from beate"
64 docker-compose logs consumer | grep k=beate
65 echo "Messages from foo"
66 docker-compose logs consumer | grep k=foo