This project is a code sample accompanying the Michelin IT Blog article on Kafka Streams Dead Letter Queue. It is valid at least up to Apache Kafka 4.3.1, but will no longer evolve.
Prerequisites • Examples • Michelin IT Blog • Current London 2025
Code sample for Kafka Streams Dead Letter Queue (KIP-1034).
- Java 25
- Maven
- Docker
- Dead Letter Queue with
errors.dead.letter.queue.topic.nameproperty. - Dead Letter Queue with custom processing exception handler.
The full article on Kafka Streams Dead Letter Queue is available on the Michelin IT Blog.
Dead Letter Queue in Kafka Streams (KIP-1034) has been presented at Current London 2025: