From: Kai Moritz 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"