X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.yml;h=a95e976be0eddb1cda90665d33de7c9d69780e50;hb=refs%2Fheads%2Fsumup-adder--springified;hp=db378220e49bac448462a6faaab48d27193ff235;hpb=6ce3e7f2a3ff4622a82e4bb1ec35a722d02e2069;p=demos%2Fkafka%2Ftraining diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index db37822..a95e976 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1,17 +1,42 @@ -consumer: - bootstrap-server: :9092 - group-id: my-consumer - client-id: peter - 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 +spring: + data: + mongodb: + uri: mongodb://juplo:training@localhost:27017 + database: juplo + kafka: + bootstrap-servers: :9092 + consumer: + group-id: my-group + key-deserializer: org.apache.kafka.common.serialization.StringDeserializer + value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer + properties: + partition.assignment.strategy: org.apache.kafka.clients.consumer.StickyAssignor + metadata.max.age.ms: 1000 + spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer + spring.json.type.mapping: > + ADD:de.juplo.kafka.MessageAddNumber, + CALC:de.juplo.kafka.MessageCalculateSum + producer: + bootstrap-servers: :9092 logging: level: root: INFO de.juplo: DEBUG server: - port: 8081 + port: 8881