4 image: confluentinc/cp-kafka:7.2.2
8 - ./kafka-1.properties:/etc/kafka/kafka.properties:ro
9 - data-1:/var/lib/data/kafka
12 image: confluentinc/cp-kafka:7.2.2
21 - ./kafka-2.properties:/etc/kafka/kafka.properties:ro
22 - data-2:/var/lib/data/kafka
25 image: confluentinc/cp-kafka:7.2.2
29 - ./kafka-3.properties:/etc/kafka/kafka.properties:ro
30 - data-3:/var/lib/data/kafka
36 kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic test
37 kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 --replication-factor 3 --config min.insync.replicas=2
38 kafka-topics --bootstrap-server kafka:9092 --describe --topic test
43 command: sleep infinity
46 image: juplo/simple-producer:1.0-SNAPSHOT
50 image: juplo/simple-consumer:1.0-SNAPSHOT
51 command: kafka:9092 test my-group consumer-1
54 image: juplo/simple-consumer:1.0-SNAPSHOT
55 command: kafka:9092 test my-group consumer-2
58 image: juplo/simple-consumer:1.0-SNAPSHOT
59 command: kafka:9092 test my-group consumer-3
65 kafka-console-consumer \
66 --bootstrap-server kafka:9092 \
67 --topic __consumer_offsets --from-beginning \
68 --formatter "kafka.coordinator.group.GroupMetadataManager\$$OffsetsMessageFormatter"