consumer:
topic: test
+ dlq-topic: dlq
management:
endpoint:
shutdown:
client-id: DEV
auto-offset-reset: earliest
group-id: my-group
- value-deserializer: org.apache.kafka.common.serialization.LongDeserializer
+ 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