juplo.de Git - demos/kafka/training/blob - src/main/resources/application.yml

   1 sumup:
   2   adder:
   3     topic: out
   4 management:
   5   endpoint:
   6     shutdown:
   7       enabled: true
   8   endpoints:
   9     web:
  10       exposure:
  11         include: "*"
  12   info:
  13     env:
  14       enabled: true
  15     java:
  16       enabled: true
  17 spring:
  18   data:
  19     mongodb:
  20       uri: mongodb://juplo:training@localhost:27017
  21       database: juplo
  22   kafka:
  23     bootstrap-servers: :9092
  24     consumer:
  25       group-id: my-group
  26       key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
  27       value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
  28       properties:
  29         partition.assignment.strategy: org.apache.kafka.clients.consumer.StickyAssignor
  30         metadata.max.age.ms: 1000
  31         spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
  32         spring.json.type.mapping: >
  33           ADD:de.juplo.kafka.MessageAddNumber,
  34           CALC:de.juplo.kafka.MessageCalculateSum
  35     producer:
  36       bootstrap-servers: :9092
  37 logging:
  38   level:
  39     root: INFO
  40     de.juplo: DEBUG
  41 server:
  42   port: 8881