mjsax commented on code in PR #19291:
URL: https://github.com/apache/kafka/pull/19291#discussion_r2032232490
##########
docs/streams/developer-guide/dsl-api.html:
##########
@@ -764,10 +764,10 @@ <h4 class="anchor-heading"><a
id="streams_concepts_globalktable" class="anchor-l
<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.
Review Comment:
Instead of removing the reference to `transform()` we should update it to
`process()` with replaces `transform()`.
--
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]
