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   mvn clean
   7   docker image rm juplo/seek:1.0-SNAPSHOT
   8   exit
   9 fi
  10
  11 docker-compose up -d zookeeper kafka
  12
  13 if [[
  14   $(docker image ls -q juplo/seek:1.0-SNAPSHOT) == "" ||
  15   "$1" = "build"
  16 ]]
  17 then
  18   mvn install || exit
  19 else
  20   echo "Using image existing images:"
  21   docker image ls juplo/seek:1.0-SNAPSHOT
  22 fi
  23
  24 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
  25 do
  26   echo "Waiting for kafka...";
  27   sleep 1;
  28 done
  29
  30 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
  31
  32 docker-compose up -d producer
  33 docker-compose up -d perter franz beate ute klaus paul sigi
  34 sleep 3
  35 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
  36 sleep 3
  37 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
  38 sleep 3
  39 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
  40
  41 docker-compose stop producer franz beate ute klaus paul sigi
  42 docker-compose logs consumer