Skip to content

Commit dc172f3

Browse files
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]>
1 parent d7ad625 commit dc172f3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: docs/streams/developer-guide/dsl-api.html

+2-2
Original file line numberDiff line numberDiff line change
@@ -764,10 +764,10 @@ <h4 class="anchor-heading"><a id="streams_concepts_globalktable" class="anchor-l
764764
<td>
765765
<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>
766766

767-
<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.
767+
Kafka Streams will manage the topic for <code><span class="pre">repartition()</span></code>.
768768
Generated topic is treated as internal topic, as a result data will be purged automatically as any other internal repartition topic.
769769
In addition, you can specify the desired number of partitions, which allows to easily scale in/out downstream sub-topologies.
770-
<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.
770+
<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.
771771

772772
<pre class="line-numbers"><code class="language-java">KStream&lt;byte[], String&gt; stream = ... ;
773773
KStream&lt;byte[], String&gt; repartitionedStream = stream.repartition(Repartitioned.numberOfPartitions(10));</code></pre>

0 commit comments

Comments
 (0)