kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: KIP-160 docs
Date Wed, 30 Aug 2017 18:17:58 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f5310d645 -> ce04b1435


MINOR: KIP-160 docs

Author: Guozhang Wang <wangguoz@gmail.com>

Reviewers: Damian Guy <damian.guy@gmail.com>

Closes #3733 from guozhangwang/KMinor-kip160-docs


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ce04b143
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ce04b143
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ce04b143

Branch: refs/heads/trunk
Commit: ce04b14358054dd33134a596de97ef5594d187b7
Parents: f5310d6
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Wed Aug 30 11:17:55 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Aug 30 11:17:55 2017 -0700

----------------------------------------------------------------------
 docs/streams/developer-guide.html | 10 +++++-----
 docs/streams/upgrade-guide.html   |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ce04b143/docs/streams/developer-guide.html
----------------------------------------------------------------------
diff --git a/docs/streams/developer-guide.html b/docs/streams/developer-guide.html
index 3af0175..d437da7 100644
--- a/docs/streams/developer-guide.html
+++ b/docs/streams/developer-guide.html
@@ -729,7 +729,7 @@ Note that in the <code>WordCountProcessor</code> implementation,
users need to r
             </td>
         </tr>
         <tr>
-            <td><b>Foreach</b>: <code>KStream &rarr; void or
KTable &rarr; void </code></td>
+            <td><b>Foreach</b>: <code>KStream &rarr; void </code></td>
             <td>
                 <p>
                 Terminal operation. Performs a stateless action on each record.
@@ -935,7 +935,7 @@ Note that in the <code>WordCountProcessor</code> implementation,
users need to r
             </td>
         </tr>
         <tr>
-            <td><b>Print</b>: <code>KStream &rarr; void or KTable
&rarr; void</code></td>
+            <td><b>Print</b>: <code>KStream &rarr; void </code></td>
             <td>
                 <p>
                 Terminal operation. Prints the records to <code>System.out</code>.
See Javadocs for serde and <code>toString()</code> caveats.
@@ -944,8 +944,8 @@ Note that in the <code>WordCountProcessor</code> implementation,
users need to r
                        KStream&lt;byte[], String&gt; stream = ...;
                        stream.print();
 
-                       // Several variants of `print` exist to e.g. override the
-                       // default serdes for record keys and record values.
+                       // Several variants of `print` exist to e.g. override the default
serdes for record keys
+                       // and record values, set a prefix label for the output string, etc
                        stream.print(Serdes.ByteArray(), Serdes.String());
                 </pre>
             </td>
@@ -995,7 +995,7 @@ Note that in the <code>WordCountProcessor</code> implementation,
users need to r
             </td>
         </tr>
         <tr>
-            <td><b>WriteAsText</b>: <code>KStream &rarr; void
or KTable &rarr; void</code></td>
+            <td><b>WriteAsText</b>: <code>KStream &rarr; void
</code></td>
             <td>
                 <p>
                 Terminal operation. Write the records to a file. See Javadocs for serde and
<code>toString()</code> caveats.

http://git-wip-us.apache.org/repos/asf/kafka/blob/ce04b143/docs/streams/upgrade-guide.html
----------------------------------------------------------------------
diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html
index 7f695f5..fd5f3f0 100644
--- a/docs/streams/upgrade-guide.html
+++ b/docs/streams/upgrade-guide.html
@@ -45,7 +45,7 @@
     </p>
 
     <h3><a id="streams_api_changes_100" href="#streams_api_changes_100">Streams
API changes in 1.0.0</a></h3>
-    <!-- TODO: KIP-120, 160, 161, 167, 173 -->
+    <!-- TODO: KIP-120, 161, 167, 173 -->
 
     <p>
         The Processor API was extended to allow users to schedule <code>punctuate</code>
functions either based on data-driven <b>stream time</b> or wall-clock time.


Mime
View raw message