X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=df6b321a490c902f1d4fdd982035a467dc400861;hb=487ca1ac0c73b1c07547d5316d145ed46490ba9d;hp=ec307f5ebf9ece93f2fbeadc72b07fb6bd476e8e;hpb=35c806a3746c673a2479c702de7a9903783c34a9;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index ec307f5..df6b321 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -24,14 +24,34 @@ services: depends_on: - zookeeper - setup: - image: juplo/toolbox - command: > - bash -c " - kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic test - kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 - " + kafka-ui: + image: provectuslabs/kafka-ui:0.3.3 + ports: + - 8080:8080 + environment: + KAFKA_CLUSTERS_0_NAME: local + KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:9092 cli: image: juplo/toolbox command: sleep infinity + + producer: + image: juplo/endless-long-producer:1.0-SNAPSHOT + ports: + - 8080:8080 + environment: + server.port: 8080 + producer.bootstrap-server: kafka:9092 + producer.client-id: producer + producer.throttle-ms: 10 + + + consumer: + image: juplo/endless-consumer:1.0-SNAPSHOT + ports: + - 8081:8080 + environment: + server.port: 8080 + consumer.bootstrap-server: kafka:9092 + consumer.client-id: consumer