X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=f4ec68049f4641913f639a9a55051c3b27dcd3e8;hb=0faf3701ab829dde908964c9c41ffc2187cff6df;hp=a874abf87f1901164c783702504a61560ca83d40;hpb=1437f0138472baefe3811ded7d3b1085845bb28e;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index a874abf..f4ec680 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -65,7 +65,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 1 --replication-factor 3 --config min.insync.replicas=2 + kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 --replication-factor 3 --config min.insync.replicas=2 kafka-topics --bootstrap-server kafka:9092 --describe --topic test " @@ -73,20 +73,32 @@ services: image: juplo/toolbox command: sleep infinity - producer: + acks-all: image: juplo/rest-producer:1.0-SNAPSHOT ports: - - 8080:8080 + - 8082:8080 environment: server.port: 8080 producer.bootstrap-server: kafka:9092 - producer.client-id: producer + producer.client-id: acks-all producer.topic: test + producer.acks: all + + acks-1: + image: juplo/rest-producer:1.0-SNAPSHOT + ports: + - 8081:8080 + environment: + server.port: 8080 + producer.bootstrap-server: kafka:9092 + producer.client-id: acks-1 + producer.topic: test + producer.acks: 1 consumer: image: juplo/endless-consumer:1.0-SNAPSHOT ports: - - 8081:8080 + - 8000:8080 environment: server.port: 8080 consumer.bootstrap-server: kafka:9092