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
