X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=f99a6390e5d2cfee2b6d9e448aa326bfe32d4295;hb=99654a4a3895f410415a29e2229a011ea307cff8;hp=4118cc43f38c65600780849d8077fd5bcc5b7d39;hpb=11bf609f474e7b399bb7ef576e4e3c544acc70ba;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index 4118cc4..f99a639 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -89,56 +89,36 @@ services: image: juplo/toolbox command: > bash -c " - kafka-topics --bootstrap-server kafka:9092 --create --if-not-exists --topic in --partitions 2 --replication-factor 3 --config min.insync.replicas=2 - kafka-topics --bootstrap-server kafka:9092 --create --if-not-exists --topic out --partitions 2 --replication-factor 3 --config min.insync.replicas=2 - kafka-topics --bootstrap-server kafka:9092 --describe --topic in - kafka-topics --bootstrap-server kafka:9092 --describe --topic out + kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic test + 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 " depends_on: - kafka-1 - kafka-2 - kafka-3 - cli: image: juplo/toolbox command: sleep infinity + depends_on: + - kafka-1 + - kafka-2 + - kafka-3 - gateway: - image: juplo/sumup-gateway--springified:1.0-SNAPSHOT - ports: - - 8080:8080 + producer: + image: juplo/supersimple-producer:1.0-SNAPSHOT environment: - server.port: 8080 spring.kafka.bootstrap-servers: kafka:9092 - spring.kafka.client-id: gateway - sumup.gateway.topic: in - - requests-1: - image: juplo/sumup-requests-json:1.0-SNAPSHOT - ports: - - 8081:8080 - environment: - server.port: 8080 - sumup.requests.bootstrap-server: kafka:9092 - sumup.requests.client-id: requests-1 - - requests-2: - image: juplo/sumup-requests-json:1.0-SNAPSHOT - ports: - - 8082:8080 - environment: - server.port: 8080 - sumup.requests.bootstrap-server: kafka:9092 - sumup.requests.client-id: requests-2 + spring.kafka.client-id: producer consumer: image: juplo/supersimple-consumer:1.0-SNAPSHOT ports: - - 8090:8080 + - 8080:8080 environment: server.port: 8080 spring.kafka.bootstrap-servers: kafka:9092 - spring.kafka.producer.bootstrap-servers: kafka:9092 - spring.kafak.client-id: consumer + spring.kafka.client-id: consumer + spring.kafka.consumer.auto-offset-reset: earliest logging.level.org.apache.kafka.clients.consumer: INFO