This is an automated email from the ASF dual-hosted git repository.
mjsax 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 dc172f3a61c MINOR: remove transform and through from repartition
description (#19291)
dc172f3a61c is described below
commit dc172f3a61c393e0c8401af408e0aa9a873a0c9a
Author: PoAn Yang <[email protected]>
AuthorDate: Wed Apr 9 09:10:25 2025 +0800
MINOR: remove transform and through from repartition description (#19291)
`transform` and `through` are removed in 4.0. Since users cannot
reference them in 4.0 document, it's not good to keep using them as
example in `repartition` description.
Reviewers: Matthias J. Sax <[email protected]>
---
docs/streams/developer-guide/dsl-api.html | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/streams/developer-guide/dsl-api.html
b/docs/streams/developer-guide/dsl-api.html
index b59ac764f32..8e8a36f76c0 100644
--- a/docs/streams/developer-guide/dsl-api.html
+++ b/docs/streams/developer-guide/dsl-api.html
@@ -764,10 +764,10 @@ KTable<byte[], String> table =
stream.toTable();</code></pre>
<td>
<p class="first">Manually trigger repartitioning
of the stream with desired number of partitions. (<a class="reference external"
href="/{{version}}/javadoc/org/apache/kafka/streams/kstream/KStream.html#repartition--">details</a>)</p>
- <code><span
class="pre">repartition()</span></code> is similar to <code><span
class="pre">through()</span></code> however Kafka Streams will manage the topic
for you.
+ Kafka Streams will manage the topic for
<code><span class="pre">repartition()</span></code>.
Generated topic is treated as internal topic, as a
result data will be purged automatically as any other internal repartition
topic.
In addition, you can specify the desired number of
partitions, which allows to easily scale in/out downstream sub-topologies.
- <code><span
class="pre">repartition()</span></code> operation always triggers
repartitioning of the stream, as a result it can be used with embedded
Processor API methods (like <code><span class="pre">transform()</span></code>
et al.) that do not trigger auto repartitioning when key changing operation is
performed beforehand.
+ <code><span
class="pre">repartition()</span></code> operation always triggers
repartitioning of the stream, as a result it can be used with embedded
Processor API methods (like <code><span class="pre">process()</span></code> et
al.) that do not trigger auto repartitioning when key changing operation is
performed beforehand.
<pre class="line-numbers"><code
class="language-java">KStream<byte[], String> stream = ... ;
KStream<byte[], String> repartitionedStream =
stream.repartition(Repartitioned.numberOfPartitions(10));</code></pre>