From fcf079d59d5b6acb8efd77c26454dc3a172dd440 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 3 Nov 2024 11:07:45 +0100
Subject: [PATCH] Setup und `README.sh` zum Aufzeigen der Auswirkungen von
 `delivery.timeout.ms`

---
 README.sh                 | 19 ++++++++++---------
 docker/docker-compose.yml |  4 +++-
 2 files changed, 13 insertions(+), 10 deletions(-)

diff --git a/README.sh b/README.sh
index 61526553..4085f72e 100755
--- a/README.sh
+++ b/README.sh
@@ -10,7 +10,7 @@ then
 fi
 
 docker compose -f docker/docker-compose.yml up -d --remove-orphans kafka-1 kafka-2 kafka-3
-docker compose -f docker/docker-compose.yml rm -svf producer
+docker compose -f docker/docker-compose.yml rm -svf setup producer
 
 if [[
   $(docker image ls -q $IMAGE) == "" ||
@@ -27,16 +27,17 @@ docker compose -f docker/docker-compose.yml up --remove-orphans setup || exit 1
 
 
 docker compose -f docker/docker-compose.yml up -d producer
-docker compose -f docker/docker-compose.yml up -d peter ute
-sleep 15
+sleep 5
+
+docker compose -f docker/docker-compose.yml pause kafka-1 kafka-3
+sleep 20
+docker compose -f docker/docker-compose.yml unpause kafka-1 kafka-3
+sleep 3
 
 docker compose -f docker/docker-compose.yml stop producer
 
 echo
-echo "Von peter empfangen:"
-docker compose -f docker/docker-compose.yml logs peter | grep '\ test\/.'
-echo
-echo "Von ute empfangen:"
-docker compose -f docker/docker-compose.yml logs ute | grep '\ test\/.'
+echo "Empfangen:"
+docker compose -f docker/docker-compose.yml exec cli kafkacat -b kafka:9092 -t test -e -q -J
 
-docker compose -f docker/docker-compose.yml stop peter ute
+docker compose -f docker/docker-compose.yml logs producer | grep ERROR
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 00f68fcc..a5fd281b 100644
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -103,7 +103,7 @@ services:
           kafka-topics --bootstrap-server kafka:9092 \
                        --create \
                        --topic test \
-                       --partitions 2 \
+                       --partitions 1 \
                        --replication-factor 3 \
                        --config min.insync.replicas=2 \
           && echo Das Topic \'test\' wurde erfolgreich angelegt: \
@@ -141,6 +141,8 @@ services:
       juplo.bootstrap-server: kafka:9092
       juplo.client-id: producer
       juplo.producer.topic: test
+      juplo.producer.delivery-timeout: 2147483647ms
+      juplo.producer.buffer-memory: 32768
 
   consumer:
     image: juplo/simple-consumer:1.0-SNAPSHOT
-- 
2.20.1