3 IMAGE=juplo/simple-consumer:1.0-SNAPSHOT
5 if [ "$1" = "cleanup" ]
11 docker-compose up -d kafka-0 kafka-1 kafka-2 kafka-3 cli
12 docker-compose rm -svf consumer-1 consumer-2 consumer-3
14 echo "Waiting for the Kafka-Cluster to become ready..."
15 docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
16 docker-compose up setup
17 docker-compose up -d producer consumer-1 consumer-2 consumer-3
20 docker-compose stop consumer-2 consumer-3
23 docker-compose start consumer-3
24 docker-compose stop consumer-1
27 docker-compose start consumer-1
30 docker-compose stop producer consumer-1 consumer-2 consumer-3
31 docker-compose logs consumer-1
33 echo "Received messages for test/0"
34 docker-compose logs consumer-1 | grep test/0
35 echo "Received messages for test/1"
36 docker-compose logs consumer-1 | grep test/1