This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a commit to branch 4.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.3 by this push:
new 1938c361f6d MINOR: Document KAFKA-20616 native memory leak in 4.3.0
upgrade guideMessage for issue with 4.3 RocksDB native memory (#22404)
1938c361f6d is described below
commit 1938c361f6d8f4ace1023cf2443af1da26552a34
Author: Bill Bejeck <[email protected]>
AuthorDate: Thu May 28 17:57:25 2026 -0400
MINOR: Document KAFKA-20616 native memory leak in 4.3.0 upgrade
guideMessage for issue with 4.3 RocksDB native memory (#22404)
Adds a Note to the 4.3.0 section of the Kafka Streams upgrade guide
warning users about the RocksDB native memory leak (KAFKA-20616) and
recommending they upgrade directly to 4.3.1 once available.
Docs-only change.
Reviewers: Matthias J. Sax <[email protected]>
---
docs/streams/upgrade-guide.md | 2 ++
1 file changed, 2 insertions(+)
diff --git a/docs/streams/upgrade-guide.md b/docs/streams/upgrade-guide.md
index 47e91c31c4f..20ba6d4228a 100644
--- a/docs/streams/upgrade-guide.md
+++ b/docs/streams/upgrade-guide.md
@@ -67,6 +67,8 @@ Since 2.6.0 release, Kafka Streams depends on a RocksDB
version that requires Ma
## Streams API changes in 4.3.0
+**Note:** Kafka Streams 4.3.0 contains a critical native memory leak in the
RocksDB state store layer
([KAFKA-20616](https://issues.apache.org/jira/browse/KAFKA-20616)). The
`ColumnFamilyOptions` for the offsets column family is not closed, and column
family handles can leak on close-path exceptions, which under cascading task
closes (e.g., rebalances or error-triggered recoveries) leads to unbounded
off-heap memory growth and eventual OOM. Users running Kafka Streams should
consider upg [...]
+
Kafka Streams now supports `ProcessingExceptionHandler` for global
store/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
store/KTables by setting the new config
`processing.exception.handler.global.enabled` to `true` (recommended). When en
[...]
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 configurat [...]
