iit2009060 commented on code in PR #21535:
URL: https://github.com/apache/kafka/pull/21535#discussion_r2893931172
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java:
##########
@@ -209,10 +209,8 @@ public void process(final Record<KIn, VIn> record) {
// like Scala or Kotlin do not, and thus we need to catch
`Exception`
// (instead of `RuntimeException`) to work well with those
languages
- // If the processing exception handler is not set (e.g., for
global threads),
+ // If the processing exception handler is not set,
// rethrow the exception to let it bubble up to the uncaught
exception handler.
- // The processing exception handler is only set for regular stream
tasks, not for
- // global state update tasks which use a different error handling
mechanism.
if (processingExceptionHandler == null) {
Review Comment:
But this is still misleading ?
'The processing exception handler is only set for regular stream tasks'
We do have a mechanism now to enable it for global state/KTable processing ?
or we should update like this 'By default The processing exception handler
is only set for regular stream tasks '
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
