iit2009060 commented on code in PR #21535:
URL: https://github.com/apache/kafka/pull/21535#discussion_r2893967841
##########
docs/streams/developer-guide/config-streams.md:
##########
@@ -1484,6 +1485,30 @@ Serde for the inner class of a windowed record. Must
implement the `Serde` inter
> }
> }
+### processing.exception.handler.global.enabled
+
+> Controls whether the configured `ProcessingExceptionHandler` is invoked for
exceptions occurring during Global KTable processing. When set to `true`, the
handler specified via `processing.exception.handler` will be invoked for
exceptions occurring during Global KTable processing. When set to `false`
(default), exceptions from Global KTables will not invoke the processing
exception handler and will instead bubble up to the configured uncaught
exception handler.
+>
+> **Default value:** `false`
+>
+> **Important Notes:**
+>
+> * Dead Letter Queue (DLQ) functionality is not supported for Global
KTables. For Global KTable exceptions, the record metadata will be logged and
the record will not be sent to the DLQ.
Review Comment:
done
##########
docs/streams/upgrade-guide.md:
##########
@@ -65,13 +65,9 @@ Since 2.6.0 release, Kafka Streams depends on a RocksDB
version that requires Ma
## Streams API changes in 4.3.0
-The streams thread metrics `commit-ratio`, `process-ratio`, `punctuate-ratio`,
and `poll-ratio`, along with streams state updater metrics
`active-restore-ratio`, `standby-restore-ratio`, `idle-ratio`, and
`checkpoint-ratio` have been updated. Each metric now reports, over a rolling
measurement window, the ratio of time this thread spends performing the given
action (`{action}`) to the total elapsed time in that window. The effective
window duration is determined by the metrics configuration:
`metrics.sample.window.ms` (per-sample window length) and `metrics.num.samples`
(number of rolling windows).
-
-### Deprecation of streams-scala module (KIP-1244)
+Kafka Streams now supports `ProcessingExceptionHandler` for Global KTable
processing via
[KIP-1270](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1270%3A+Extend+ProcessExceptionalHandler+for+GlobalThread).
Previously, the `ProcessingExceptionHandler` only applied to regular stream
tasks. With this release, you can now configure exception handling for Global
KTables by setting the new config `processing.exception.handler.global.enabled`
to `true`. When enabled, the configured `ProcessingExceptionHandler` will be
invoked for exceptions occurring during Global KTable processing. Note that
Dead Letter Queue (DLQ) support is not yet available for Global KTables and
will be added in an upcoming release. More details can be found in
[KIP-1270](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1270%3A+Extend+ProcessExceptionalHandler+for+GlobalThread).
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]
