conduktor.io ↗

KIP-1270 — Introduce ProcessExceptionalHandler for Global Thread

Accepted Kafka 4.3 Streams

Extends the ProcessingExceptionHandler to cover GlobalStreamThread processors (GlobalKTable), with a new processing.exception.handler.global.enabled boolean config to opt in. Currently any exception in GlobalKTable record processing kills the GlobalStreamThread and shuts down the entire Streams application, unlike regular KStream/KTable processing where the handler can recover gracefully.

Details

AuthorArpit Goyal
StatusAccepted
Kafka Version4.3
JIRAKAFKA-19939
WikiView on Apache Wiki
Created2026-01-03
Last Modified2026-02-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.