From 2e4f55b72fef8f55d37d773e265064225fe66a45 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 25 May 2025 13:27:15 +0200 Subject: [PATCH] README --- README.sh | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/README.sh b/README.sh index f1d4061..e7cc216 100755 --- a/README.sh +++ b/README.sh @@ -1,15 +1,23 @@ #!/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 \ @@ -27,3 +35,6 @@ docker compose exec cli kafka-acls \ --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 -- 2.20.1