consumer: topic: test dlq-topic: dlq 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: kafka: consumer: bootstrap-servers: :9092 client-id: DEV auto-offset-reset: earliest group-id: my-group value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer properties: spring.deserializer.value.delegate.class: "org.springframework.kafka.support.serializer.JsonDeserializer" spring.json.type.mapping: "message:de.juplo.kafka.ClientMessage,greeting:de.juplo.kafka.Greeting" spring.json.trusted.packages: "de.juplo.kafka" producer: bootstrap-servers: :9092 client-id: DEV value-serializer: org.apache.kafka.common.serialization.ByteArraySerializer logging: level: root: INFO de.juplo: DEBUG server: port: 8881