Skip to content

Commit

Permalink
MINOR: KIP-307 upgrade guide docs (apache#7547)
Browse files Browse the repository at this point in the history
Reviewers: John Roesler <[email protected]>, Matthias J. Sax <[email protected]>
  • Loading branch information
bbejeck authored and mjsax committed Oct 21, 2019
1 parent 7bc8c0d commit 7bef73d
Showing 1 changed file with 14 additions and 1 deletion.
15 changes: 14 additions & 1 deletion docs/streams/upgrade-guide.html
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,20 @@ <h1>Upgrade Guide and API Changes</h1>
<h3><a id="streams_api_changes_240" href="#streams_api_changes_240">Streams API changes in 2.4.0</a></h3>

<!-- Placeholder KIP-213 -->
<!-- Placeholder KIP-307 -->
<p>
In the 2.4 release, you now can name all operators in a Kafka Streams DSL topology via
<a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-307%3A+Allow+to+define+custom+processor+names+with+KStreams+DSL">KIP-307</p>.
Giving your operators meaningful names makes it easier to understand the topology
description (<code>Topology#describe()#toString()</code>) and
understand the full context of what your Kafka Streams application is doing.
<br />
There are new overloads on most <code>KStream</code> and <code>KTable</code> methods
that accept a <code>Named</code> object. Typically you'll provide a name for the DSL operation by
using <code>Named.as("my operator name")</code>. Naming of repartition topics for aggregation
operations will still use <code>Grouped</code> and join operations will use
either <code>Joined</code> or the new <code>StreamJoined</code> object.

</p>
<!-- Placeholder KIP-479 -->

<p>
Expand Down

0 comments on commit 7bef73d

Please sign in to comment.