Skip to content

Latest commit

 

History

History
34 lines (22 loc) · 2.93 KB

File metadata and controls

34 lines (22 loc) · 2.93 KB
Apache Kafka

Kafka Streams Dead Letter Queue in Spring Kafka

GitHub Build Spring Boot Version License

PrerequisitesExamplesMichelin IT Blog

Code sample for Spring-friendly Kafka Streams Dead Letter Queue (KIP-1034) in Spring Kafka.

Prerequisites

  • Java 25
  • Maven
  • Docker

Examples

Module Description API
Dead Letter Destination Resolver Spring-friendly dead letter queue routing logic KafkaStreamsDeadLetterDestinationResolver, KafkaStreamsConfiguration
Dead Letter Publishing Recoverer Original Spring Kafka dead letter queue DeadLetterPublishingRecoverer, KafkaStreamsConfiguration
Dead Letter Topic Name Straightforward way to send to a predefined dead letter topic StreamsBuilderFactoryBean, errors.dead.letter.queue.topic.name
Recovering Exception Handlers Use the provided recovering exception handlers KafkaStreamsConfiguration, deserialization.exception.handler, processing.exception.handler, production.exception.handler

Michelin IT Blog

Soon to be published.