Setup mit ein bischen mehr Dampf (`README.sh` angepasst)
authorKai Moritz <kai@juplo.de>
Sat, 2 Nov 2024 17:38:18 +0000 (18:38 +0100)
committerKai Moritz <kai@juplo.de>
Thu, 6 Feb 2025 16:55:40 +0000 (17:55 +0100)
README.sh
docker/docker-compose.yml

index cf72e51..07f7de4 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
index a8c9f0f..d58151a 100644 (file)
@@ -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: