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 5
  25
  26 docker-compose start consumer-1
  27 sleep 5
  28
  29 docker-compose stop producer consumer-1 consumer-2 consumer-3
  30 docker-compose logs consumer-1
  31
  32 echo "Received messages for test/0"
  33 docker-compose logs consumer-1 | grep test/0
  34 echo "Received messages for test/1"
  35 docker-compose logs consumer-1 | grep test/1