From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 May 2025 14:43:46 +0000 (+0200)
Subject: STEP-ONE
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=5507f11a69c04c641a0c94612d9866fa496965a5;p=demos%2Fkafka%2Ftraining

STEP-ONE
---

diff --git a/README.sh b/README.sh
deleted file mode 100755
index e7cc216..0000000
--- a/README.sh
+++ /dev/null
@@ -1,40 +0,0 @@
-#!/bin/bash
-
-echo "Starting Zookeeper"
-docker compose up -d zookeeper
-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
-
-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 \
-  --bootstrap-server kafka:9092 \
-  --add \
-  --allow-principal User:client \
-  --topic test \
-  --consumer --group=my-group \
-  --producer
-
-docker compose exec cli kafka-acls \
-  --command-config /mnt/admin.properties \
-  --bootstrap-server kafka:9092 \
-  --list \
-  --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
diff --git a/STEP-ONE.sh b/STEP-ONE.sh
new file mode 100755
index 0000000..a78cc8e
--- /dev/null
+++ b/STEP-ONE.sh
@@ -0,0 +1,46 @@
+#!/bin/bash
+
+echo "Stoping old setup and delting all data..."
+docker compose down -v -t0 --remove-orphans
+
+echo "Starting Zookeeper"
+docker compose up -d zookeeper
+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
+
+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 \
+  --bootstrap-server kafka:9092 \
+  --add \
+  --allow-principal User:client \
+  --topic test \
+  --consumer --group=my-group \
+  --producer
+
+docker compose exec cli kafka-acls \
+  --command-config /mnt/admin.properties \
+  --bootstrap-server kafka:9092 \
+  --list \
+  --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
+echo 
+echo "Watch the producer in a separate window with:"
+echo "docker compose logs -f --tail=10 producer consumer"