This is an automated email from the ASF dual-hosted git repository. mjsax pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.5 by this push: new 704c5a6 KAFKA-9758: Doc changes for KIP-523 and KIP-527 (#8343) 704c5a6 is described below commit 704c5a6d355c37fa6239d8b23453a0c189ee67a3 Author: Boyang Chen <boy...@confluent.io> AuthorDate: Wed Mar 25 09:31:00 2020 -0700 KAFKA-9758: Doc changes for KIP-523 and KIP-527 (#8343) Reviewer: Matthias J. Sax <matth...@confluent.io> --- docs/streams/developer-guide/datatypes.html | 4 ++++ docs/streams/developer-guide/dsl-api.html | 14 ++++++++++++++ docs/streams/upgrade-guide.html | 8 ++++++++ 3 files changed, 26 insertions(+) diff --git a/docs/streams/developer-guide/datatypes.html b/docs/streams/developer-guide/datatypes.html index ecdb48c..1871b18 100644 --- a/docs/streams/developer-guide/datatypes.html +++ b/docs/streams/developer-guide/datatypes.html @@ -144,6 +144,10 @@ <tr class="row-even"><td>UUID</td> <td><code class="docutils literal"><span class="pre">Serdes.UUID()</span></code></td> </tr> + </tr> + <tr class="row-odd"><td>Void</td> + <td><code class="docutils literal"><span class="pre">Serdes.Void()</span></code></td> + </tr> </tbody> </table> <div class="admonition tip"> diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index ad762a8..5ad0791 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -849,6 +849,20 @@ </div> </td> </tr> + <tr class="row-even"><td><p class="first"><strong>Stream to Table</strong></p> + <ul class="last simple"> + <li>KStream → KTable</li> + </ul> + </td> + <td><p class="first">Convert an event stream into a table, or say a changelog stream. + (<a class="reference external" href="/{{version}}/javadoc/org/apache/kafka/streams/kstream/KStream.html#toTable--">details</a>)</p> + <div class="last highlight-java"><div class="highlight"><pre><span></span><span class="n">KStream</span><span class="o"><</span><span class="kt">byte</span><span class="o">[],</span> <span class="n">String</span><span class="o">></span> <span class="n">stream</span> <span class="o">=</span> <span class="o">...;</span> + +<span class="n">KTable</span><span class="o"><</span><span class="kt">byte</span><span class="o">[],</span> <span class="n">String</span><span class="o">></span> <span class="n">table</span> <span class="o">=</span> <span class="n">stream</span><span class="o">.</span><span class="na">toTable</span><span class="o">();</span> +</pre></div> + </div> + </td> + </tr> </tbody> </table> </div> diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html index 1d261546..78f1ccc 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -80,6 +80,14 @@ We refer to the <a href="/{{version}}/documentation/streams/developer-guide/dsl-api.html">developer guide</a> for more details. </p> <p> + We added a new <code>KStream.toTable()</code> API to translate an input event stream into a changelog stream as per + <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-523%3A+Add+KStream%23toTable+to+the+Streams+DSL">KIP-523</a>. + </p> + <p> + We added a new Serde type <code>Void</code> in <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-527%3A+Add+VoidSerde+to+Serdes">KIP-527</a> to represent + null keys or null values from input topic. + </p> + <p> As of 2.5.0 Kafka we deprecated <code>UsePreviousTimeOnInvalidTimestamp</code> and replaced it with <code>UsePartitionTimeOnInvalidTimeStamp</code> as per <a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=130028807">KIP-530</a> </p>