Hi Team Just reaching out again.Need your inputs to move it forward Thanks and Regards Arpit Goyal 8861094754
On Thu, 8 Jan, 2026, 10:03 pm Arpit Goyal, <[email protected]> wrote: > Hi All, > I would like to start a discussion for KIP-1270. This KIP extends > ProcessingExceptionHandler support to GlobalKTable processors, enabling > consistent exception handling across all stream processing types. > > * Current Behavior* > > When a processing exception occurs in a GlobalKTable processor: > - The exception propagates to GlobalStreamThread > - The GlobalStreamThread terminates > - The entire Kafka Streams application shuts down > - No user-configurable exception handling is available > > * Proposed Behavior* > > After this KIP, when a processing exception occurs in a GlobalKTable > processor: > - The configured ProcessingExceptionHandler.handleError() will be invoked > - If the handler returns Result.RESUME, processing continues with the > next record > - If the handler returns Result.FAIL, the exception propagates (same as > current behavior) > - If no handler is configured, behavior remains unchanged (backward > compatible) > > KIP: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1270%3A+Introduce+ProcessExceptionalHandler+for+GlobalThread > > Thanks and Regards > Arpit Goyal > 8861094754 >
