You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/03/25 16:32:23 UTC
[kafka] branch 2.5 updated: KAFKA-9758: Doc changes for KIP-523 and
KIP-527 (#8343)
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 <bo...@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 <ma...@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>