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
   8   exit
   9 fi
  10
  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
  13
  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
  18 sleep 5
  19
  20 docker-compose stop consumer-2 consumer-3
  21 sleep 5
  22
  23 docker-compose start consumer-3
  24 docker-compose stop consumer-1
  25 sleep 5
  26
  27 docker-compose start consumer-1
  28 sleep 5
  29
  30 docker-compose stop producer consumer-1 consumer-2 consumer-3
  31 docker-compose logs consumer-1
  32
  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