version: '3.2'
services:
zookeeper:
- image: confluentinc/cp-zookeeper:6.2.0
+ image: confluentinc/cp-zookeeper:7.1.3
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ports:
- 2181:2181
kafka:
- image: confluentinc/cp-kafka:6.2.0
+ image: confluentinc/cp-kafka:7.1.3
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
- zookeeper
kafka-ui:
- image: provectuslabs/kafka-ui:0.2.1
+ image: provectuslabs/kafka-ui:0.3.3
ports:
- 8080:8080
environment:
ports:
- 8000:8080
environment:
+ server.port: 8080
producer.bootstrap-server: kafka:9092
producer.client-id: producer
producer.topic: test
producer.throttle-ms: 10
- count-0:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 0 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
-
- count-1:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 1 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
-
- count-2:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 2 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
-
- count-3:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 3 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
-
- count-4:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 4 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
-
- count-5:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 5 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
-
- count-6:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 6 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
- count-7:
- image: juplo/toolbox
- command: >
- bash -c "
- kafka-console-consumer \
- --bootstrap-server kafka:9092 \
- --topic test \
- --partition 7 \
- --property print.key=true \
- --property print.value=false \
- --from-beginning \
- --timeout-ms 1000 2>/dev/null | sort | uniq -c
- "
+ consumer:
+ image: juplo/endless-consumer:1.0-SNAPSHOT
+ ports:
+ - 8081:8080
+ environment:
+ server.port: 8080
+ consumer.bootstrap-server: kafka:9092
+ consumer.client-id: my-group
+ consumer.client-id: consumer
+ consumer.topic: test