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

   1 #!/bin/bash
   2
   3 if [ "$1" = "cleanup" ]
   4 then
   5   docker-compose down -v
   6   exit
   7 fi
   8
   9 docker-compose up -d zookeeper kafka
  10
  11 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
  12 do
  13   echo "Waiting for kafka...";
  14   sleep 1;
  15 done
  16
  17 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 1 --topic foo
  18
  19 docker-compose up -d producer consumer
  20
  21 sleep 3
  22 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group bar --reset-offsets --to-earliest
  23 sleep 3
  24 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group bar --reset-offsets --to-earliest
  25 sleep 3
  26 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group bar --reset-offsets --to-earliest
  27
  28 docker-compose stop producer consumer
  29 docker-compose logs consumer