From: Kai Moritz Date: Sat, 23 Jul 2022 11:28:38 +0000 (+0200) Subject: Merge der überarbeiteten Compose-Konfiguration ('endless-stream-consumer') X-Git-Tag: spikzettel-DEPRECATED~1 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fscaling;p=demos%2Fkafka%2Ftraining Merge der überarbeiteten Compose-Konfiguration ('endless-stream-consumer') --- d772dacfe24223a782313c96b88bb1f3a8d90219 diff --cc docker-compose.yml index b7da4ca,159f9cb..a93ee5a --- a/docker-compose.yml +++ b/docker-compose.yml @@@ -54,48 -55,6 +55,49 @@@ services environment: server.port: 8080 consumer.bootstrap-server: kafka:9092 - consumer.client-id: my-group - consumer.client-id: consumer + consumer.group-id: my-group + consumer.client-id: peter consumer.topic: test + + beate: + image: juplo/endless-consumer:1.0-SNAPSHOT + ports: + - 8082:8080 + environment: + server.port: 8080 + consumer.bootstrap-server: kafka:9092 + consumer.group-id: my-group + consumer.client-id: beate + consumer.topic: test + + franz: + image: juplo/endless-consumer:1.0-SNAPSHOT + ports: + - 8083:8080 + environment: + server.port: 8080 + consumer.bootstrap-server: kafka:9092 + consumer.group-id: my-group + consumer.client-id: franz + consumer.topic: test + + klaus: + image: juplo/endless-consumer:1.0-SNAPSHOT + ports: + - 8084:8080 + environment: ++ server.port: 8080 + consumer.bootstrap-server: kafka:9092 + consumer.group-id: my-group + consumer.client-id: klaus + consumer.topic: test + + spikzettel: + image: juplo/toolbox + command: > + bash -c ' + kafka-console-consumer \ + --bootstrap-server kafka:9092 \ + --topic __consumer_offsets --from-beginning \ + --formatter "kafka.coordinator.group.GroupMetadataManager\$$OffsetsMessageFormatter" + '