Thanks for the KIP Arpit.
Can you elaborate a little bit more on details? With the newly added DLQ
support for regular `Processor`, the existing
`ProcessingHandlerResponse` and corresponding method `handle()` are
deprecated with upcoming 4.2 release.
Thus, from AK 4.2+ going forward, users are expected to not implement
the old `handle()` (even if it's still supported, as long as the new
`handleError` is not overwritten).
Are you proposing, for now, to only add support for the deprecated
`handle()` method, ie, the new `handleError()` method would not be
called by the global-thread code? If yes, this might be confusing for users?
If you do not propose this, would it imply that the global-thread code
would call the new `handlerError()` method? For this case, the question
is what the runtime would do if users try to use the DLQ feature?
Overall, it's unclear to me what you propose in detail and how we can
avoid to confuse users, keep it backward compatible, and make it easy to
understanding how the handler will work.
-Matthias
On 1/10/26 8:33 AM, Arpit Goyal wrote:
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
