simple: consumer: topic: test management: endpoint: shutdown: enabled: true endpoints: web: exposure: include: "*" info: env: enabled: true java: enabled: true info: kafka: bootstrap-server: ${spring.kafka.bootstrap-servers} client-id: ${spring.kafka.client-id} group-id: ${spring.kafka.consumer.group-id} topic: ${simple.consumer.topic} auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset} spring: 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 de.juplo: DEBUG server: port: 8881