kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 2.5 updated: KAFKA-9758: Doc changes for KIP-523 and KIP-527 (#8343)
Date Wed, 25 Mar 2020 16:32:23 GMT
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 <boyang@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 <matthias@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 &rarr; 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">&lt;</span><span class="kt">byte</span><span
class="o">[],</span> <span class="n">String</span><span class="o">&gt;</span>
<span class="n">stream</span> <span class="o">=</span> <span class="o">...;</span>
+
+<span class="n">KTable</span><span class="o">&lt;</span><span
class="kt">byte</span><span class="o">[],</span> <span class="n">String</span><span
class="o">&gt;</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>


Mime
View raw message