juplo.de Git - demos/kafka/training/blob - README.sh

   1 #!/bin/bash
   2
   3 IMAGE=juplo/simple-consumer:1.0-SNAPSHOT
   4
   5 if [ "$1" = "cleanup" ]
   6 then
   7   docker-compose down -v --remove-orphans
   8   exit
   9 fi
  10
  11 docker-compose up -d kafka-1 kafka-2 kafka-3 cli
  12 docker-compose rm -svf consumer-1 consumer-2 consumer-3
  13
  14 docker-compose up setup
  15 docker-compose up -d producer consumer-1 consumer-2 consumer-3
  16 docker-compose ps
  17 sleep 5
  18
  19 docker-compose stop consumer-2 consumer-3
  20 sleep 5
  21
  22 docker-compose start consumer-3
  23 docker-compose stop consumer-1
  24 sleep 1
  25 docker-compose start consumer-2
  26 sleep 5
  27
  28 docker-compose start consumer-1
  29 sleep 5
  30
  31 docker-compose stop producer consumer-1 consumer-2 consumer-3
  32 docker-compose logs consumer-1
  33
  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