Kafka Streams Dead Letter Queue in Spring Kafka

Prerequisites • Examples • Michelin 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.