X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.yml;h=92f3a6b3541f131c477549e3b7536629b45f2e5e;hb=0c9a0c1cf9a0065012743efcd940d8721bc33c20;hp=51c031b6998860321740265af949dda132a10a25;hpb=bd31d01723e93a992856aba344485e3493019c2a;p=demos%2Fkafka%2Ftraining diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 51c031b..92f3a6b 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1,14 +1,46 @@ -consumer: - bootstrap-server: :9092 - group-id: my-group - client-id: DEV - topic: test - auto-offset-reset: earliest +sumup: + adder: + topic: out management: + endpoint: + shutdown: + enabled: true endpoints: web: exposure: include: "*" + info: + env: + enabled: true + java: + enabled: true +info: + kafka: + bootstrap-server: ${spring.kafka.consumer.bootstrap-servers} + client-id: ${spring.kafka.consumer.client-id} + group-id: ${spring.kafka.consumer.group-id} + topic: ${consumer.topic} + auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset} +spring: + data: + mongodb: + uri: mongodb://juplo:training@localhost:27017 + database: juplo + kafka: + bootstrap-servers: :9092 + client-id: DEV + consumer: + group-id: my-group + auto-offset-reset: earliest + auto-commit-interval: 5s + key-deserializer: org.apache.kafka.common.serialization.StringDeserializer + value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer + properties: + partition.assignment.strategy: org.apache.kafka.clients.consumer.StickyAssignor + metadata.max.age.ms: 1000 + spring.json.type.mapping: > + ADD:de.juplo.kafka.MessageAddNumber, + CALC:de.juplo.kafka.MessageCalculateSum logging: level: root: INFO