+++ /dev/null
-#!/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
--- /dev/null
+#!/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"