Skip to content
This repository was archived by the owner on Oct 7, 2026. It is now read-only.

About

Code sample for Kafka Streams processing error handling (KIP-1033).

Topics

Resources

Code of conduct

Contributing

Stars

4 stars

Watchers

3 watching

Forks

Repository files navigation

This project is a code sample accompanying the Michelin IT Blog article on Kafka Streams processing error handling. It is valid at least up to Apache Kafka 4.3.1, but will no longer evolve.

Apache Kafka

Processing Error Handling

GitHub Build Kafka Version License

Prerequisites • Examples • Michelin IT Blog • Current London 2025

Code sample for Kafka Streams processing error handling (KIP-1033).

Prerequisites

  • Java 25
  • Maven
  • Docker

Examples

  • Processing Error Handling with DSL.
  • Processing Error Handling with Processor API.

Michelin IT Blog

The full article on processing error handling in Kafka Streams is available on the Michelin IT Blog.

Current London 2025

Processing Error Handling (KIP-1033) has been presented at Current London 2025:

  • Slides are available here.
  • Replay is available online.

About

Code sample for Kafka Streams processing error handling (KIP-1033).

Topics

Resources

Code of conduct

Contributing

Stars

4 stars

Watchers

3 watching

Forks

Used by

Contributors

Languages