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

   1 #!/bin/bash
   2
   3 RECORDER=juplo/wordcount--recorder:1.0.0
   4 USERS=juplo/wordcount--users:1.0.0
   5 COUNTER=juplo/wordcount--counter:1.0.0
   6 TOP10=juplo/wordcount--top10:1.0.0
   7 QUERY=juplo/wordcount--query:1.0.2
   8
   9 if [ "$1" = "cleanup" ]
  10 then
  11   docker-compose down -v
  12   docker image rm $RECORDER
  13   docker image rm $USERS
  14   docker image rm $COUNTER
  15   docker image rm $TOP10
  16   docker image rm $QUERY
  17   exit
  18 fi
  19
  20 if [[
  21   $(docker image ls -q $RECORDER) == "" ||
  22   $(docker image ls -q $USERS) == "" ||
  23   $(docker image ls -q $COUNTER) == "" ||
  24   $(docker image ls -q $TOP10) == "" ||
  25   $(docker image ls -q $QUERY) == "" ||
  26   "$1" = "build"
  27 ]]
  28 then
  29   git submodule update --init
  30   mvn clean package || exit
  31   docker-compose rm -svf recorder users counter top10 query
  32   mvn -f recorder/pom.xml docker:build
  33   mvn -f users/pom.xml docker:build
  34   mvn -f counter/pom.xml docker:build
  35   mvn -f top10/pom.xml docker:build
  36   mvn -f query/pom.xml docker:build
  37 else
  38   echo "Using existing images:"
  39   docker image ls $RECORDER
  40   docker image ls $USERS
  41   docker image ls $COUNTER
  42   docker image ls $TOP10
  43   docker image ls $QUERY
  44 fi
  45
  46
  47 docker-compose up -d zookeeper kafka cli kafkacat
  48
  49 echo "Waiting for the Kafka-Cluster to become ready..."
  50 docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
  51 docker-compose exec cli zookeeper-shell zookeeper:2181 ls /brokers/ids
  52
  53 echo "Starting all instances..."
  54 docker-compose up -d