Setup und `README.sh` zum Aufzeigen der Auswirkungen von `delivery.timeout.ms`

diff --git a/README.sh b/README.sh
index c8a0b221b5f6e6cb2ca15e8b8c3c100a5e0c45e5..918e83abe45997051481f4c8cd8df18200dba46d 100755 (executable)
--- 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 00f68fcc477576d720a14eeff9dac33e44627817..a5fd281b6d9782daf0839280402fb32855f75c36 100644 (file)
--- 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