Merge der überarbeiteten Compose-Konfiguration ('endless-stream-consumer') scaling
authorKai Moritz <kai@juplo.de>
Sat, 23 Jul 2022 11:28:38 +0000 (13:28 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 23 Jul 2022 11:32:41 +0000 (13:32 +0200)
1  2 
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"
 +      '