KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false"
ports:
- 9081:9081
+ depends_on:
+ - kafka-0
kafka-2:
image: bitnami/kafka:3.3.1
default:
aliases:
- kafka
+ depends_on:
+ - kafka-0
kafka-3:
image: bitnami/kafka:3.3.1
KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false"
ports:
- 9083:9083
+ depends_on:
+ - kafka-0
+
setup:
image: juplo/toolbox
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
+ command: kafka:9092 test producer
- consumer-3:
+ consumer:
image: juplo/simple-consumer:1.0-SNAPSHOT
- command: kafka:9092 test my-group consumer-3
-
- 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"
- '
+ command: kafka:9092 test my-group consumer