#!/bin/bash
+echo "Starting Zookeeper"
docker compose up -d zookeeper
-sleep 10
+while (($(echo -n srvr | nc localhost 2181 | wc -l ) < 9))
+do
+ echo "Waiting for Zookeeper..."
+ sleep 1
+done
+
+echo "Setting a (arbitratry) fix Cluster ID"
docker compose exec zookeeper zookeeper-shell zookeeper:2181 create /cluster
docker compose exec zookeeper zookeeper-shell zookeeper:2181 create /cluster/id
docker compose exec zookeeper zookeeper-shell zookeeper:2181 set /cluster/id '{"version":"1","id":"8e-KqCzwQPqK7EibrzJE5g"}'
docker compose exec zookeeper zookeeper-shell zookeeper:2181 get /cluster/id
-docker compose up -d producer consumer
+echo "Starting Kafka in Zookeeper-Mode..."
docker compose up setup
+echo "Setting up ACLs for the consumer and the producer..."
# client
docker compose exec cli kafka-acls \
--command-config /mnt/admin.properties \
--user-principal User:client \
--group=my-group \
--topic test
+
+echo "Starting a producer and a consumer in the background..."
+docker compose up -d producer consumer