Setup mit ein bischen mehr Dampf (`README.sh` angepasst)

diff --git a/README.sh b/README.sh
index cf72e51302f71148e8c28c03affbb26917ef8777..07f7de4ce6c7b8d3cfd07c4f4dd8418262a5be77 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 consumer
+docker compose -f docker/docker-compose.yml rm -svf consumer-1
 
 if [[
   $(docker image ls -q $IMAGE) == "" ||
@@ -27,13 +27,9 @@ 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 consumer
+docker compose -f docker/docker-compose.yml up -d consumer-1
 
-sleep 5
-docker compose -f docker/docker-compose.yml stop consumer
+sleep 10
+docker compose -f docker/docker-compose.yml exec cli http consumer-1:8881/
 
-docker compose -f docker/docker-compose.yml start consumer
-sleep 5
-
-docker compose -f docker/docker-compose.yml stop producer consumer
-docker compose -f docker/docker-compose.yml logs consumer
+docker compose -f docker/docker-compose.yml stop producer consumer-1

diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index a8c9f0fddd7a6a8b4f83f28e80c88aa0f9196a93..d58151ab827958f743821b19b9ed1f3031e5a4d6 100644 (file)
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -161,7 +161,7 @@ services:
       juplo.client-id: producer
       juplo.producer.topic: test
       juplo.producer.linger-ms: 666
-      juplo.producer.throttle-ms: 100
+      juplo.producer.throttle-ms: 10
 
   consumer:
     image: juplo/spring-consumer:1.1-log-compaction-SNAPSHOT
@@ -169,20 +169,26 @@ services:
       juplo.bootstrap-server: kafka:9092
       juplo.client-id: consumer
       juplo.consumer.topic: test
+      juplo.producer.linger-ms: 1000
+      logging.level.de.juplo: TRACE
 
   peter:
-    image: juplo/spring-consumer:1.1-SNAPSHOT
+    image: juplo/spring-consumer:1.1-log-compaction-SNAPSHOT
     environment:
       juplo.bootstrap-server: kafka:9092
       juplo.client-id: peter
       juplo.consumer.topic: test
+      juplo.producer.linger-ms: 1000
+      logging.level.de.juplo: TRACE
 
   ute:
-    image: juplo/spring-consumer:1.1-SNAPSHOT
+    image: juplo/spring-consumer:1.1-log-compaction-SNAPSHOT
     environment:
       juplo.bootstrap-server: kafka:9092
       juplo.client-id: ute
       juplo.consumer.topic: test
+      juplo.producer.linger-ms: 1000
+      logging.level.de.juplo: TRACE
 
 volumes:
   zookeeper-data: