You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/06/05 05:42:47 UTC

kafka git commit: MINOR: update docs with regard to KIP-123

Repository: kafka
Updated Branches:
  refs/heads/trunk 3557f097b -> d4a070fcf


MINOR: update docs with regard to KIP-123

Author: Matthias J. Sax <ma...@confluent.io>

Reviewers: Guozhang Wang <wa...@gmail.com>

Closes #3232 from mjsax/minor-update-docs-for-kip-123


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

Branch: refs/heads/trunk
Commit: d4a070fcfae97a5ec0681f7055385c6459727956
Parents: 3557f09
Author: Matthias J. Sax <ma...@confluent.io>
Authored: Sun Jun 4 22:42:44 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Sun Jun 4 22:42:44 2017 -0700

----------------------------------------------------------------------
 docs/streams.html | 30 ++++++++++++++++++++++--------
 1 file changed, 22 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/d4a070fc/docs/streams.html
----------------------------------------------------------------------
diff --git a/docs/streams.html b/docs/streams.html
index 4528d9d..4e07cfa 100644
--- a/docs/streams.html
+++ b/docs/streams.html
@@ -825,18 +825,32 @@ $ java -cp path-to-app-fatjar.jar com.example.MyStreamsApp
         See <a href="#streams_api_changes_0101">below</a> a complete list of 0.10.1 API changes that allow you to advance your application and/or simplify your code base, including the usage of new features.
         </p>
 
-        <h3><a id="streams_api_changes_0110" href="#streams_api_changes_0110">Notable changes in 0.11.0.0</a></h3>
+        <h3><a id="streams_api_changes_0110" href="#streams_api_changes_0110">Streams API changes in 0.11.0.0</a></h3>
 
-        <p>
-        Parameter updates in <code>StreamsConfig</code>:
-        </p>
+        <p> Updates in <code>StreamsConfig</code>: </p>
+        <ul>
+          <li> configuration parameter <code>key.serde</code> was deprecated and replaced by <code>default.key.serde</code>
+          <li> configuration parameter <code>value.serde</code> was deprecated and replaced by <code>default.value.serde</code>
+          <li> configuration parameter <code>timestamp.extractor</code> was deprecated and replaced by <code>default.timestamp.extractor</code>
+          <li> method <code>#keySerde()</code> was deprecated and replaced by <code>#defaultKeySerde()</code>
+          <li> method <code>#valueSerde()</code> was deprecated and replaced by <code>#defaultValueSerde()</code>
+          <li> new method <code>#defaultTimestampExtractor()</code> was added </code>
+        </ul>
+
+        <p> New methods in <code>TopologyBuilder</code>: </p>
+        <ul>
+            <li> added overloads for <code>#addSource()</code> that allow to define a <code>TimestampExtractor</code> per source node </li>
+            <li> added overloads for <code>#addGlobalStore()</code> that allow to define a <code>TimestampExtractor</code> per source node associated with the global store </li>
+        </ul>
+
+        <p> New methods in <code>KStreamBuilder</code>: </p>
         <ul>
-          <li> <code>timestamp.extractor</code> was deprecated and replaced by <code>default.timestamp.extractor</code>
-          <li> <code>key.serde</code> was deprecated and replaced by <code>default.key.serde</code>
-          <li> <code>value.serde</code> was deprecated and replaced by <code>default.value.serde</code>
+            <li> added overloads for <code>#stream()</code> that allow to define a <code>TimestampExtractor</code> per input stream </li>
+            <li> added overloads for <code>#table()</code> that allow to define a <code>TimestampExtractor</code> per input table </li>
+            <li> added overloads for <code>#globalKTable()</code> that allow to define a <code>TimestampExtractor</code> per global table </li>
         </ul>
 
-        <h3><a id="streams_api_changes_01021" href="#streams_api_changes_01021">Notable changes in 0.10.2.1</a></h3>
+        <h3><a id="streams_api_changes_01021" href="#streams_api_changes_01021">Stream API changes in 0.10.2.1</a></h3>
 
         <p>
         Parameter updates in <code>StreamsConfig</code>: