iit2009060 commented on code in PR #21535:
URL: https://github.com/apache/kafka/pull/21535#discussion_r2893965041
##########
docs/streams/developer-guide/config-streams.md:
##########
@@ -75,6 +75,7 @@ This section contains the most common Streams configuration
parameters. For a fu
* num.stream.threads
* probing.rebalance.interval.ms
* processing.exception.handler
+ * processing.exception.handler.global.enabled
Review Comment:
done
##########
docs/streams/developer-guide/config-streams.md:
##########
@@ -1446,7 +1447,7 @@ Serde for the inner class of a windowed record. Must
implement the `Serde` inter
> The processing exception handler allows you to manage exceptions triggered
> during the processing of a record. The implemented exception handler needs
> to return a `FAIL` or `CONTINUE` depending on the record and the exception
> thrown. Returning `FAIL` will signal that Streams should shut down and
> `CONTINUE` will signal that Streams should ignore the issue and continue
> processing.
>
-> **Note:** This handler applies only to regular stream processing tasks. It
does not apply to global state store updates (global threads). Exceptions
occurring in global threads will bubble up to the configured uncaught exception
handler.
+> **Note:** By default, this handler applies only to regular stream processing
tasks. To enable exception handling for Global KTable processing, see
`processing.exception.handler.global.enabled` below. When global exception
handling is disabled (default), exceptions occurring during Global KTable
processing will bubble up to the configured uncaught exception handler.
Review Comment:
done
--
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]
