This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 81b1bf31e87 MINOR: Fix documentation typos in protocol and upgrade
guides (#22262)
81b1bf31e87 is described below
commit 81b1bf31e87f8ada3a6b8730d7f9d685eaed0eb3
Author: Arpit Jain <[email protected]>
AuthorDate: Thu May 14 21:05:57 2026 +0900
MINOR: Fix documentation typos in protocol and upgrade guides (#22262)
## Summary
- Fix typos in docs:
- `implementors` -> `implementers` (protocol docs and upgrade guide)
- malformed `Optiona...` type in Streams upgrade guide corrected to
`Optional<Set<Integer>> StreamPartitioner.partitions()`
## Why
Small docs-only cleanup from a focused codespell and readability pass.
Reviewers: Chia-Ping Tsai <[email protected]>
---
docs/streams/upgrade-guide.md | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/docs/streams/upgrade-guide.md b/docs/streams/upgrade-guide.md
index da69b5c8af8..3f38449bfc4 100644
--- a/docs/streams/upgrade-guide.md
+++ b/docs/streams/upgrade-guide.md
@@ -300,7 +300,7 @@ We added a new Serde type `Boolean` in
[KIP-907](https://cwiki.apache.org/conflu
[KIP-770](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=186878390)
deprecates config `cache.max.bytes.buffering` in favor of the newly introduced
config `statestore.cache.max.bytes`. To improve monitoring, two new metrics
`input-buffer-bytes-total` and `cache-size-bytes-total` were added at the DEBUG
level. Note, that the KIP is only partially implemented in the 3.4.0 release,
and config `input.buffer.max.bytes` is not available yet.
-[KIP-873](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211883356)
enables you to multicast result records to multiple partition of downstream
sink topics and adds functionality for choosing to drop result records without
sending. The `Integer StreamPartitioner.partition()` method is deprecated and
replaced by the newly added
`Optiona≶Set<Integer>>StreamPartitioner.partitions()` method, which enables
returning a set of partitions to send the record to.
+[KIP-873](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211883356)
enables you to multicast result records to multiple partition of downstream
sink topics and adds functionality for choosing to drop result records without
sending. The `Integer StreamPartitioner.partition()` method is deprecated and
replaced by the newly added `Optional<Set<Integer>>
StreamPartitioner.partitions()` method, which enables returning a set of
partitions to send the record to.
[KIP-862](https://cwiki.apache.org/confluence/x/WSf1D) adds a DSL optimization
for stream-stream self-joins. The optimization is enabled via a new option
`single.store.self.join` which can be set via existing config
`topology.optimization`. If enabled, the DSL will use a different join
processor implementation that uses a single RocksDB store instead of two, to
avoid unnecessary data duplication for the self-join case.
@@ -592,4 +592,3 @@ compatible
* [Documentation](/documentation)
* [Kafka Streams](/documentation/streams)
-
