X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=9ca05c88e392d06cbba6e30514517be45a89843c;hb=03f72c8fd6f0461b8cf690c76134d7470746ff98;hp=336c459dbf6dd210ed22fe9c637b85433875c401;hpb=6aa275cf310f594d3f86620fb9200591ebe11c75;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index 336c459..9ca05c8 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -1,14 +1,14 @@ version: '3.2' services: zookeeper: - image: confluentinc/cp-zookeeper:7.0.2 + image: confluentinc/cp-zookeeper:7.1.3 environment: ZOOKEEPER_CLIENT_PORT: 2181 ports: - 2181:2181 kafka: - image: confluentinc/cp-kafka:7.0.2 + image: confluentinc/cp-kafka:7.1.3 environment: KAFKA_BROKER_ID: 1 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 @@ -29,7 +29,7 @@ services: 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-topics --bootstrap-server kafka:9092 --create --topic test --partitions 1 " cli: @@ -39,16 +39,68 @@ services: producer: image: juplo/rest-producer:1.0-SNAPSHOT ports: - - 8080:8080 + - 8080:8880 environment: producer.bootstrap-server: kafka:9092 producer.client-id: producer producer.topic: test + producer.batch-size: 16384 + producer.linger-ms: 5000 + + peter: + image: juplo/rest-client:1.0-SNAPSHOT + ports: + - 8081:8080 + environment: + server.port: 8080 + rest-client.baseUrl: http://producer:8080 + rest-client.username: peter + rest-client.throttle-ms: 1 + + klaus: + image: juplo/rest-client:1.0-SNAPSHOT + ports: + - 8082:8080 + environment: + server.port: 8080 + rest-client.baseUrl: http://producer:8080 + rest-client.username: klaus + rest-client.throttle-ms: 1 + + beate: + image: juplo/rest-client:1.0-SNAPSHOT + ports: + - 8083:8080 + environment: + server.port: 8080 + rest-client.baseUrl: http://producer:8080 + rest-client.username: beate + rest-client.throttle-ms: 1 + + franz: + image: juplo/rest-client:1.0-SNAPSHOT + ports: + - 8084:8080 + environment: + server.port: 8080 + rest-client.baseUrl: http://producer:8080 + rest-client.username: franz + rest-client.throttle-ms: 1 + + uschi: + image: juplo/rest-client:1.0-SNAPSHOT + ports: + - 8085:8080 + environment: + server.port: 8080 + rest-client.baseUrl: http://producer:8080 + rest-client.username: uschi + rest-client.throttle-ms: 1 consumer: - image: juplo/counting-consumer:1.0-SNAPSHOT + image: juplo/endless-consumer:1.0-SNAPSHOT ports: - - 8081:8081 + - 8000:8081 environment: consumer.bootstrap-server: kafka:9092 consumer.client-id: my-group