X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=90d6e0e6e7067f8608ae400f598c59f717956edc;hb=refs%2Ftags%2Fspring-consumer--kafkalistener---2023-06-signal;hp=293db15facd97ac0c0466c8448a473f4a0a688fe;hpb=0f05c15fff4472bdfdbdca9219b3bfbd7da3ee93;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index 293db15..90d6e0e 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -34,6 +34,8 @@ services: KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false" ports: - 9081:9081 + depends_on: + - kafka-0 kafka-2: image: bitnami/kafka:3.3.1 @@ -58,6 +60,8 @@ services: default: aliases: - kafka + depends_on: + - kafka-0 kafka-3: image: bitnami/kafka:3.3.1 @@ -77,6 +81,9 @@ services: KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false" ports: - 9083:9083 + depends_on: + - kafka-0 + setup: image: juplo/toolbox @@ -86,33 +93,29 @@ services: kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 --replication-factor 3 --config min.insync.replicas=2 kafka-topics --bootstrap-server kafka:9092 --describe --topic test " + depends_on: + - kafka-1 + - kafka-2 + - kafka-3 cli: image: juplo/toolbox command: sleep infinity + depends_on: + - kafka-1 + - kafka-2 + - kafka-3 producer: - image: juplo/simple-producer:1.0-SNAPSHOT - command: producer - - consumer-1: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer-1 - - consumer-2: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer-2 - - consumer-3: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer-3 + image: juplo/supersimple-producer:1.0-SNAPSHOT + environment: + spring.kafka.bootstrap-servers: kafka:9092 + spring.kafka.client-id: producer - 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" - ' + consumer: + image: juplo/spring-consumer-kafkalistener:1.0-SNAPSHOT + environment: + spring.kafka.bootstrap-servers: kafka:9092 + spring.kafka.client-id: consumer + spring.kafka.consumer.auto-offset-reset: earliest + logging.level.org.apache.kafka.clients.consumer: INFO