3 IMAGE=juplo/round-robin:1.0-SNAPSHOT
5 if [ "$1" = "cleanup" ]
12 docker-compose up -d zookeeper kafka cli
15 $(docker image ls -q $IMAGE) == "" ||
21 echo "Using image existing images:"
22 docker image ls $IMAGE
25 echo "Waiting for the Kafka-Cluster to become ready..."
26 docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
27 docker-compose up -d kafka-ui
29 docker-compose exec -T cli bash << 'EOF'
30 echo "Creating topic with 3 partitions..."
31 kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic test
33 kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 3
35 kafka-topics --bootstrap-server kafka:9092 --describe --topic test
38 docker-compose up -d producer consumer
49 docker-compose exec -T cli bash << 'EOF'
50 echo "Altering number of partitions from 3 to 7..."
52 kafka-topics --bootstrap-server kafka:9092 --alter --topic test --partitions 7
53 kafka-topics --bootstrap-server kafka:9092 --describe --topic test
70 http -v post :8081/stop
71 http -v post :8081/start
90 docker-compose stop producer consumer