X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=b428c916b2508e7dfe4522401f3c3b7a0d48eaa6;hb=3a58bcc84bc7698b0648d57be0dce208789ade00;hp=a16bf67b4ad7759bd3896f31d21fd1e2870fa433;hpb=17ea973592446fa9c88618db9f1a14aafca6ebd4;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index a16bf67..b428c91 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -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: @@ -45,11 +45,63 @@ services: 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/endless-consumer:1.0-SNAPSHOT ports: - - 8081:8080 + - 8000:8080 environment: server.port: 8080 consumer.bootstrap-server: kafka:9092