From 401a87f7e94f950f294cd46f776f091d3bd0f49b Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 1 Dec 2023 14:05:25 +0100 Subject: [PATCH] =?utf8?q?Spickzettel-=C3=9Cbung=20auf=20den=20Spring-Cons?= =?utf8?q?umer=20umgestellt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- docker/docker-compose.yml | 27 +++++++++++++++++++-------- 1 file changed, 19 insertions(+), 8 deletions(-) diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml index 678b9ca..fbe8b35 100644 --- a/docker/docker-compose.yml +++ b/docker/docker-compose.yml @@ -188,20 +188,31 @@ services: - kafka-3 producer: - image: juplo/simple-producer:1.0-SNAPSHOT - command: kafka:9092 test producer + image: juplo/endless-stream-spring-producer:1.0-SNAPSHOT + environment: + producer.throttle-ms: 1 + spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092 + spring.kafka.client-id: producer + spring.kafka.template.default-topic: test + spring.kafka.producer.properties.linger.ms: 100 consumer-1: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer-1 + image: juplo/spring-consumer:1.0-SNAPSHOT + environment: + spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092 + spring.kafka.client-id: consumer-1 consumer-2: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer-2 + image: juplo/spring-consumer:1.0-SNAPSHOT + environment: + spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092 + spring.kafka.client-id: consumer-2 consumer-3: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer-3 + image: juplo/spring-consumer:1.0-SNAPSHOT + environment: + spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092 + spring.kafka.client-id: consumer-3 spickzettel: image: juplo/toolbox -- 2.20.1