From b8aa72282f61598309200c3a84f3fb60eed8cef3 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 9 Nov 2024 09:15:08 +0100 Subject: [PATCH] 3 Consumern mit 3 unterschiedlichen Topics aber nur EINER Group-ID --- docker/docker-compose.yml | 42 +++++++++++++++++++++++++++++++++++++-- 1 file changed, 40 insertions(+), 2 deletions(-) diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml index 40e56fc9..a65ee3e6 100644 --- a/docker/docker-compose.yml +++ b/docker/docker-compose.yml @@ -137,11 +137,21 @@ services: echo -n Bereits konfiguriert: cat INITIALIZED kafka-topics --bootstrap-server kafka:9092 --describe --topic test + kafka-topics --bootstrap-server kafka:9092 --describe --topic foo + kafka-topics --bootstrap-server kafka:9092 --describe --topic bar else kafka-topics --bootstrap-server kafka:9092 \ --delete \ --if-exists \ --topic test + kafka-topics --bootstrap-server kafka:9092 \ + --delete \ + --if-exists \ + --topic foo + kafka-topics --bootstrap-server kafka:9092 \ + --delete \ + --if-exists \ + --topic bar kafka-topics --bootstrap-server kafka:9092 \ --create \ --topic test \ @@ -150,11 +160,31 @@ services: --config min.insync.replicas=2 \ && echo Das Topic \'test\' wurde erfolgreich angelegt: \ && kafka-topics --bootstrap-server kafka:9092 --describe --topic test \ + && kafka-topics --bootstrap-server kafka:9092 \ + --create \ + --topic foo \ + --partitions 2 \ + --replication-factor 3 \ + --config min.insync.replicas=2 \ + && echo Das Topic \'foo\' wurde erfolgreich angelegt: \ + && kafka-topics --bootstrap-server kafka:9092 --describe --topic foo \ + && kafka-topics --bootstrap-server kafka:9092 \ + --create \ + --topic bar \ + --partitions 2 \ + --replication-factor 3 \ + --config min.insync.replicas=2 \ + && echo Das Topic \'bar\' wurde erfolgreich angelegt: \ + && kafka-topics --bootstrap-server kafka:9092 --describe --topic bar \ && date > INITIALIZED fi stop_grace_period: 0s depends_on: - cli + - akhq + - producer + - producer-foo + - producer-bar zoonavigator: image: elkozmon/zoonavigator:1.1.2 @@ -193,17 +223,25 @@ services: image: juplo/simple-producer:1.0-SNAPSHOT command: kafka:9092 test producer + producer-foo: + image: juplo/simple-producer:1.0-SNAPSHOT + command: kafka:9092 foo producer-foo + + producer-bar: + image: juplo/simple-producer:1.0-SNAPSHOT + command: kafka:9092 bar producer-bar + consumer: image: juplo/simple-consumer:1.0-SNAPSHOT command: kafka:9092 test my-group consumer peter: image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group peter + command: kafka:9092 foo my-group peter ute: image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group ute + command: kafka:9092 bar my-group ute volumes: zookeeper-data: -- 2.20.1