- kafka-1-data:/var/lib/kafka/data
ports:
- 9081:9081
+ stop_grace_period: 120s
depends_on:
- zookeeper
default:
aliases:
- kafka
+ stop_grace_period: 120s
depends_on:
- zookeeper
- kafka-3-data:/var/lib/kafka/data
ports:
- 9083:9083
+ stop_grace_period: 120s
depends_on:
- zookeeper
depends_on:
- schema-registry
+ cli:
+ image: juplo/toolbox
+ command: sleep infinity
+ stop_grace_period: 0s
+ depends_on:
+ - kafka-1
+ - kafka-2
+ - kafka-3
+
setup:
image: juplo/toolbox
command:
- bash
- -c
- |
+ cub kafka-ready -b kafka-1:9092,kafka-2:9092,kafka-3:9092 3 60 > /dev/null 2>&1 || exit 1
if [ -e INITIALIZED ]
then
echo -n Bereits konfiguriert:
&& kafka-topics --bootstrap-server kafka:9092 --describe --topic test \
&& date > INITIALIZED
fi
+ stop_grace_period: 0s
depends_on:
- - kafka-1
- - kafka-2
- - kafka-3
+ - cli
+
+ zoonavigator:
+ image: elkozmon/zoonavigator:1.1.2
+ ports:
+ - "8000:80"
+ environment:
+ HTTP_PORT: 80
+ CONNECTION_JUPLO_NAME: juplo
+ CONNECTION_JUPLO_CONN: zookeeper:2181
+ AUTO_CONNECT_CONNECTION_ID: JUPLO
+ depends_on:
+ - zookeeper
akhq:
image: tchiotludo/akhq:0.23.0
- kafka-2
- kafka-3
- cli:
- image: juplo/toolbox
- command: sleep infinity
- depends_on:
- - setup
+ producer:
+ image: juplo/endless-stream-spring-producer:1.0-SNAPSHOT
+ environment:
+ producer.throttle-ms: 1
+ spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
+ spring.kafka.client-id: producer
+ spring.kafka.template.default-topic: test
+ spring.kafka.producer.properties.linger.ms: 100
+
+ consumer-1:
+ image: juplo/spring-consumer:1.0-SNAPSHOT
+ environment:
+ spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
+ spring.kafka.client-id: consumer-1
+
+ consumer-2:
+ image: juplo/spring-consumer:1.0-SNAPSHOT
+ environment:
+ spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
+ spring.kafka.client-id: consumer-2
+
+ consumer-3:
+ image: juplo/spring-consumer:1.0-SNAPSHOT
+ environment:
+ spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
+ spring.kafka.client-id: consumer-3
volumes:
zookeeper-data: