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 docker-compose up -d peter franz
  25 echo "Waiting for the Kafka-Cluster to become ready..."
  26 docker-compose exec kafka cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
  27
  28 docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
  29
  30 docker-compose up -d producer
  31
  32 sleep 3
  33 http -v post :8001/start
  34 sleep 3
  35 echo 0 | http -v :8001/seek
  36 sleep 3
  37 echo 0 | http -v :8001/seek
  38
  39 http -v post :8002/start
  40 sleep 10
  41 echo 0 | http -v :8001/seek
  42 sleep 3
  43
  44 docker-compose stop producer peter franz
  45 docker-compose logs peter