fi
echo "Waiting for the Kafka-Cluster to become ready..."
-docker-compose exec kafka cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
+docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
docker-compose up -d kafka-ui
docker-compose exec -T cli bash << 'EOF'
kafka-topics --bootstrap-server kafka:9092 --describe --topic test
EOF
-docker-compose up -d producer
+docker-compose up -d producer consumer
+
sleep 10
-docker-compose stop producer
-docker-compose up count-0
-docker-compose up count-1
-docker-compose up count-2
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
docker-compose exec -T cli bash << 'EOF'
echo "Altering number of partitions from 3 to 7..."
# end::altertopic[]
EOF
-docker-compose up -d producer
-sleep 10
-docker-compose stop producer
-docker-compose up count-0
-docker-compose up count-1
-docker-compose up count-2
-docker-compose up count-3
-docker-compose up count-4
-docker-compose up count-5
-docker-compose up count-6
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
-docker-compose exec -T cli bash << 'EOF'
-echo "Recreating topic with 7 partitions..."
-# tag::recreatetopic[]
-kafka-topics --bootstrap-server kafka:9092 --delete --topic test
-kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 7
-kafka-topics --bootstrap-server kafka:9092 --describe --topic test
-# end::recreatetopic[]
-EOF
+http -v post :8081/stop
+http -v post :8081/start
-docker-compose up -d producer
-sleep 10
-docker-compose stop producer
-docker-compose up count-0
-docker-compose up count-1
-docker-compose up count-2
-docker-compose up count-3
-docker-compose up count-4
-docker-compose up count-5
-docker-compose up count-6
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
+sleep 1
+http -v :8081/seen
-docker-compose stop producer
+docker-compose stop producer consumer