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

   1 #!/bin/bash
   2 #
   3 # Führt so noch nix sinnvolles vor!
   4 # Skript passt nicht zu Implementierung.
   5 # Implementierung macht (noch?) keinen Sinn.
   6
   7 if [ "$1" = "cleanup" ]
   8 then
   9   docker-compose down -v
  10   mvn clean
  11   docker image rm juplo/seek:1.0-SNAPSHOT
  12   exit
  13 fi
  14
  15 docker-compose up -d zookeeper kafka
  16
  17 if [[
  18   $(docker image ls -q juplo/seek:1.0-SNAPSHOT) == "" ||
  19   "$1" = "build"
  20 ]]
  21 then
  22   mvn install || exit
  23 else
  24   echo "Using image existing images:"
  25   docker image ls juplo/seek:1.0-SNAPSHOT
  26 fi
  27
  28 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
  29 do
  30   echo "Waiting for kafka...";
  31   sleep 1;
  32 done
  33
  34 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
  35
  36 docker-compose up -d producer
  37 docker-compose up -d peter franz beate ute klaus paul siggi
  38 sleep 3
  39 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
  40 sleep 3
  41 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
  42 sleep 3
  43 docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
  44
  45 docker-compose stop producer franz beate ute klaus paul sigi
  46 docker-compose logs consumer