3 IMAGE=juplo/simple-consumer:1.0-SNAPSHOT
5 if [ "$1" = "cleanup" ]
7 docker-compose down -v --remove-orphans
11 docker-compose up -d kafka-1 kafka-2 kafka-3 cli
12 docker-compose rm -svf consumer-1 consumer-2 consumer-3
14 docker-compose up setup
15 docker-compose up -d producer consumer-1 consumer-2 consumer-3
19 docker-compose stop consumer-2 consumer-3
22 docker-compose start consumer-3
23 docker-compose stop consumer-1
25 docker-compose start consumer-2
28 docker-compose start consumer-1
31 docker-compose stop producer consumer-1 consumer-2 consumer-3
32 docker-compose logs consumer-1
34 echo "Messages received by consumer-1 for test/0"
35 docker-compose logs consumer-1 | grep test/0
36 echo "Messages received by consumer-2 for test/0"
37 docker-compose logs consumer-2 | grep test/0
38 echo "Messages received by consumer-3 for test/0"
39 docker-compose logs consumer-3 | grep test/0
40 echo "Messages received by consumer-1 for test/1"
41 docker-compose logs consumer-1 | grep test/1
42 echo "Messages received by consumer-2 for test/1"
43 docker-compose logs consumer-2 | grep test/1
44 echo "Messages received by consumer-3 for test/1"
45 docker-compose logs consumer-3 | grep test/1