X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.yml;h=ee1bb64282d9fcf28ba86af1ce231add17154247;hb=69ff8ad389db01433ec621f8daf2a31b3e8c5294;hp=0bc592cccfdf133ed008a4a22211f0c73ec1a2b3;hpb=ac154bb18a6c575fe01e70cba6a86d10580dfb89;p=demos%2Fkafka%2Ftraining diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 0bc592c..ee1bb64 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -1,6 +1,3 @@ -sumup: - adder: - topic: out management: endpoint: shutdown: @@ -14,40 +11,9 @@ management: 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.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 - properties: - spring.json.type.mapping: > - ADD:de.juplo.kafka.MessageAddNumber, - CALC:de.juplo.kafka.MessageCalculateSum logging: level: root: INFO