3 Consumern mit 3 unterschiedlichen Topics aber nur EINER Group-ID

diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 18c8047..0ecf0bf 100644 (file)
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -95,11 +95,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 \
@@ -108,11 +118,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
 
   akhq:
     image: tchiotludo/akhq:0.23.0
@@ -139,17 +169,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: