You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2017/04/07 23:57:52 UTC
[2/6] kafka-site git commit: Add 0.10.2 docs from 0.10.2.1 RC0
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/ForeachAction.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/ForeachAction.html b/0102/javadoc/org/apache/kafka/streams/kstream/ForeachAction.html
index 14865ab..9022f45 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/ForeachAction.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/ForeachAction.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>ForeachAction (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>ForeachAction (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ForeachAction (kafka 0.10.2.0 API)";
+ parent.document.title="ForeachAction (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/GlobalKTable.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/GlobalKTable.html b/0102/javadoc/org/apache/kafka/streams/kstream/GlobalKTable.html
index 630b87e..bf9ea73 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/GlobalKTable.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/GlobalKTable.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>GlobalKTable (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>GlobalKTable (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="GlobalKTable (kafka 0.10.2.0 API)";
+ parent.document.title="GlobalKTable (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Initializer.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Initializer.html b/0102/javadoc/org/apache/kafka/streams/kstream/Initializer.html
index 0b9e6cd..719b109 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Initializer.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Initializer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Initializer (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>Initializer (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Initializer (kafka 0.10.2.0 API)";
+ parent.document.title="Initializer (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/JoinWindows.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/JoinWindows.html b/0102/javadoc/org/apache/kafka/streams/kstream/JoinWindows.html
index a037837..fd2935d 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/JoinWindows.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/JoinWindows.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>JoinWindows (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>JoinWindows (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="JoinWindows (kafka 0.10.2.0 API)";
+ parent.document.title="JoinWindows (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html b/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html
index 736eba3..6678dae 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>KGroupedStream (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>KGroupedStream (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KGroupedStream (kafka 0.10.2.0 API)";
+ parent.document.title="KGroupedStream (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedTable.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedTable.html b/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedTable.html
index 419450f..68183b4 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedTable.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/KGroupedTable.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>KGroupedTable (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>KGroupedTable (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KGroupedTable (kafka 0.10.2.0 API)";
+ parent.document.title="KGroupedTable (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/KStream.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/KStream.html b/0102/javadoc/org/apache/kafka/streams/kstream/KStream.html
index 53d5f7e..00e8afc 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/KStream.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/KStream.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>KStream (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>KStream (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KStream (kafka 0.10.2.0 API)";
+ parent.document.title="KStream (kafka 0.10.2.1 API)";
}
//-->
</script>
@@ -1424,7 +1424,11 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> (for one input stream) before doing the
+ join, using a pre-created topic with the "correct" number of partitions.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner).
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1497,7 +1501,11 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> (for one input stream) before doing the
+ join, using a pre-created topic with the "correct" number of partitions.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner).
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1574,7 +1582,11 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> (for one input stream) before doing the
+ join, using a pre-created topic with the "correct" number of partitions.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner).
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1651,7 +1663,11 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> (for one input stream) before doing the
+ join, using a pre-created topic with the "correct" number of partitions.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner).
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1731,7 +1747,11 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td><K3:ValueJoiner(null,c)></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> (for one input stream) before doing the
+ join, using a pre-created topic with the "correct" number of partitions.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner).
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1809,7 +1829,11 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td><K3:ValueJoiner(null,c)></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> (for one input stream) before doing the
+ join, using a pre-created topic with the "correct" number of partitions.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner).
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1889,8 +1913,12 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td><K1:ValueJoiner(C,b)></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key (cf.
- <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>join(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>).
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> for this <code>KStream</code> before doing
+ the join, using a pre-created topic with the same number of partitions as the given <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner);
+ cf. <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>join(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>.
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1899,7 +1927,7 @@ public interface <span class="strong">KStream<K,V></span></pre>
"-repartition" is a fixed suffix.
You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
<p>
- Repartitioning can happen only for this <code>KStream</code>s.
+ Repartitioning can happen only for this <code>KStream</code> but not for the provided <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
For this case, all data of the stream will be redistributed through the repartitioning topic by writing all
records to it, and rereading all records from it, such that the join input <code>KStream</code> is partitioned
correctly on its key.</div>
@@ -1960,8 +1988,12 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td><K1:ValueJoiner(C,b)></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key (cf.
- <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>join(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>).
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> for this <code>KStream</code> before doing
+ the join, using a pre-created topic with the same number of partitions as the given <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner);
+ cf. <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>join(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>.
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -1970,7 +2002,7 @@ public interface <span class="strong">KStream<K,V></span></pre>
"-repartition" is a fixed suffix.
You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
<p>
- Repartitioning can happen only for this <code>KStream</code>s.
+ Repartitioning can happen only for this <code>KStream</code> but not for the provided <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
For this case, all data of the stream will be redistributed through the repartitioning topic by writing all
records to it, and rereading all records from it, such that the join input <code>KStream</code> is partitioned
correctly on its key.</div>
@@ -2035,8 +2067,12 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td><K1:ValueJoiner(C,b)></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key (cf.
- <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>).
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> for this <code>KStream</code> before doing
+ the join, using a pre-created topic with the same number of partitions as the given <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner);
+ cf. <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>join(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>.
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -2045,7 +2081,7 @@ public interface <span class="strong">KStream<K,V></span></pre>
"-repartition" is a fixed suffix.
You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
<p>
- Repartitioning can happen only for this <code>KStream</code>s.
+ Repartitioning can happen only for this <code>KStream</code> but not for the provided <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
For this case, all data of the stream will be redistributed through the repartitioning topic by writing all
records to it, and rereading all records from it, such that the join input <code>KStream</code> is partitioned
correctly on its key.</div>
@@ -2109,8 +2145,12 @@ public interface <span class="strong">KStream<K,V></span></pre>
<td><K1:ValueJoiner(C,b)></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key (cf.
- <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>).
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.
+ If this is not the case, you would need to call <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#through(java.lang.String)"><code>through(String)</code></a> for this <code>KStream</code> before doing
+ the join, using a pre-created topic with the same number of partitions as the given <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
+ Furthermore, both input streams need to be co-partitioned on the join key (i.e., use the same partitioner);
+ cf. <a href="../../../../../org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,%20org.apache.kafka.streams.kstream.KeyValueMapper,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>join(GlobalKTable, KeyValueMapper, ValueJoiner)</code></a>.
If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
@@ -2119,7 +2159,7 @@ public interface <span class="strong">KStream<K,V></span></pre>
"-repartition" is a fixed suffix.
You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
<p>
- Repartitioning can happen only for this <code>KStream</code>s.
+ Repartitioning can happen only for this <code>KStream</code> but not for the provided <a href="../../../../../org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.
For this case, all data of the stream will be redistributed through the repartitioning topic by writing all
records to it, and rereading all records from it, such that the join input <code>KStream</code> is partitioned
correctly on its key.</div>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html b/0102/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html
index 6fca301..66d7f87 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>KStreamBuilder (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>KStreamBuilder (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KStreamBuilder (kafka 0.10.2.0 API)";
+ parent.document.title="KStreamBuilder (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/KTable.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/KTable.html b/0102/javadoc/org/apache/kafka/streams/kstream/KTable.html
index 749196e..e194230 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/KTable.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/KTable.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>KTable (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>KTable (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KTable (kafka 0.10.2.0 API)";
+ parent.document.title="KTable (kafka 0.10.2.1 API)";
}
//-->
</script>
@@ -988,19 +988,8 @@ public interface <span class="strong">KTable<K,V></span></pre>
<td><K1:null></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
- If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
- internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
- The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
- user-specified in <a href="../../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a> via parameter
- <a href="../../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>APPLICATION_ID_CONFIG</code></a>, "XXX" is an internally generated name, and
- "-repartition" is a fixed suffix.
- You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
- <p>
- Repartitioning can happen both input <code>KTable</code>s.
- For this case, all data of a <code>KTable</code> will be redistributed through the repartitioning topic by writing all
- update records to and rereading all update records from it, such that the join input <code>KTable</code> is
- partitioned correctly on its key.</div>
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>VO</code> - the value type of the other <code>KTable</code></dd><dd><code>VR</code> - the value type of the result <code>KTable</code></dd><dt><span class="strong">Parameters:</span></dt><dd><code>other</code> - the other <code>KTable</code> to be joined with this <code>KTable</code></dd><dd><code>joiner</code> - a <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a> that computes the join result for a pair of matching records</dd>
<dt><span class="strong">Returns:</span></dt><dd>a <code>KTable</code> that contains join-records for each key and values computed by the given
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a>, one for each matched record-pair with the same key</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/streams/kstream/KTable.html#leftJoin(org.apache.kafka.streams.kstream.KTable,%20org.apache.kafka.streams.kstream.ValueJoiner)"><code>leftJoin(KTable, ValueJoiner)</code></a>,
@@ -1080,19 +1069,8 @@ public interface <span class="strong">KTable<K,V></span></pre>
<td></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
- If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
- internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
- The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
- user-specified in <a href="../../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a> via parameter
- <a href="../../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>APPLICATION_ID_CONFIG</code></a>, "XXX" is an internally generated name, and
- "-repartition" is a fixed suffix.
- You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
- <p>
- Repartitioning can happen both input <code>KTable</code>s.
- For this case, all data of a <code>KTable</code> will be redistributed through the repartitioning topic by writing all
- update records to and rereading all update records from it, such that the join input <code>KTable</code> is
- partitioned correctly on its key.</div>
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>VO</code> - the value type of the other <code>KTable</code></dd><dd><code>VR</code> - the value type of the result <code>KTable</code></dd><dt><span class="strong">Parameters:</span></dt><dd><code>other</code> - the other <code>KTable</code> to be joined with this <code>KTable</code></dd><dd><code>joiner</code> - a <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a> that computes the join result for a pair of matching records</dd>
<dt><span class="strong">Returns:</span></dt><dd>a <code>KTable</code> that contains join-records for each key and values computed by the given
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a>, one for each matched record-pair with the same key plus one for each non-matching record of
@@ -1172,19 +1150,8 @@ public interface <span class="strong">KTable<K,V></span></pre>
<td><K1:null></td>
</tr>
</table>
- Both input streams need to be co-partitioned on the join key.
- If this requirement is not met, Kafka Streams will automatically repartition the data, i.e., it will create an
- internal repartitioning topic in Kafka and write and re-read the data via this topic before the actual join.
- The repartitioning topic will be named "${applicationId}-XXX-repartition", where "applicationId" is
- user-specified in <a href="../../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a> via parameter
- <a href="../../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>APPLICATION_ID_CONFIG</code></a>, "XXX" is an internally generated name, and
- "-repartition" is a fixed suffix.
- You can retrieve all generated internal topic names via <a href="../../../../../org/apache/kafka/streams/KafkaStreams.html#toString()"><code>KafkaStreams.toString()</code></a>.
- <p>
- Repartitioning can happen both input <code>KTable</code>s.
- For this case, all data of a <code>KTable</code> will be redistributed through the repartitioning topic by writing all
- update records to and rereading all update records from it, such that the join input <code>KTable</code> is
- partitioned correctly on its key.</div>
+ Both input streams (or to be more precise, their underlying source topics) need to have the same number of
+ partitions.</div>
<dl><dt><span class="strong">Type Parameters:</span></dt><dd><code>VO</code> - the value type of the other <code>KTable</code></dd><dd><code>VR</code> - the value type of the result <code>KTable</code></dd><dt><span class="strong">Parameters:</span></dt><dd><code>other</code> - the other <code>KTable</code> to be joined with this <code>KTable</code></dd><dd><code>joiner</code> - a <a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a> that computes the join result for a pair of matching records</dd>
<dt><span class="strong">Returns:</span></dt><dd>a <code>KTable</code> that contains join-records for each key and values computed by the given
<a href="../../../../../org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><code>ValueJoiner</code></a>, one for each matched record-pair with the same key plus one for each non-matching record of
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/KeyValueMapper.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/KeyValueMapper.html b/0102/javadoc/org/apache/kafka/streams/kstream/KeyValueMapper.html
index 58a0c16..baf3e1a 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/KeyValueMapper.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/KeyValueMapper.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>KeyValueMapper (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>KeyValueMapper (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KeyValueMapper (kafka 0.10.2.0 API)";
+ parent.document.title="KeyValueMapper (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Merger.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Merger.html b/0102/javadoc/org/apache/kafka/streams/kstream/Merger.html
index 0cdc430..542844c 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Merger.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Merger.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Merger (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>Merger (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Merger (kafka 0.10.2.0 API)";
+ parent.document.title="Merger (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Predicate.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Predicate.html b/0102/javadoc/org/apache/kafka/streams/kstream/Predicate.html
index 02cb5ef..767f9e3 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Predicate.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Predicate.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Predicate (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>Predicate (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Predicate (kafka 0.10.2.0 API)";
+ parent.document.title="Predicate (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Reducer.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Reducer.html b/0102/javadoc/org/apache/kafka/streams/kstream/Reducer.html
index 30df954..c4454ff 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Reducer.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Reducer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Reducer (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>Reducer (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Reducer (kafka 0.10.2.0 API)";
+ parent.document.title="Reducer (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html b/0102/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html
index a1064fe..7f117c1 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>SessionWindows (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>SessionWindows (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="SessionWindows (kafka 0.10.2.0 API)";
+ parent.document.title="SessionWindows (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/TimeWindows.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/TimeWindows.html b/0102/javadoc/org/apache/kafka/streams/kstream/TimeWindows.html
index 9dad867..ea3eb0e 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/TimeWindows.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/TimeWindows.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>TimeWindows (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TimeWindows (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TimeWindows (kafka 0.10.2.0 API)";
+ parent.document.title="TimeWindows (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Transformer.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Transformer.html b/0102/javadoc/org/apache/kafka/streams/kstream/Transformer.html
index 25cee34..766db2c 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Transformer.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Transformer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Transformer (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>Transformer (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Transformer (kafka 0.10.2.0 API)";
+ parent.document.title="Transformer (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/TransformerSupplier.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/TransformerSupplier.html b/0102/javadoc/org/apache/kafka/streams/kstream/TransformerSupplier.html
index 93772a0..67ec93b 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/TransformerSupplier.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/TransformerSupplier.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>TransformerSupplier (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TransformerSupplier (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TransformerSupplier (kafka 0.10.2.0 API)";
+ parent.document.title="TransformerSupplier (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/UnlimitedWindows.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/UnlimitedWindows.html b/0102/javadoc/org/apache/kafka/streams/kstream/UnlimitedWindows.html
index eccca5d..84b0031 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/UnlimitedWindows.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/UnlimitedWindows.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>UnlimitedWindows (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>UnlimitedWindows (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="UnlimitedWindows (kafka 0.10.2.0 API)";
+ parent.document.title="UnlimitedWindows (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/ValueJoiner.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/ValueJoiner.html b/0102/javadoc/org/apache/kafka/streams/kstream/ValueJoiner.html
index b03b638..d828a68 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/ValueJoiner.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/ValueJoiner.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>ValueJoiner (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>ValueJoiner (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ValueJoiner (kafka 0.10.2.0 API)";
+ parent.document.title="ValueJoiner (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/ValueMapper.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/ValueMapper.html b/0102/javadoc/org/apache/kafka/streams/kstream/ValueMapper.html
index 10ba005..45b641b 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/ValueMapper.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/ValueMapper.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>ValueMapper (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>ValueMapper (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ValueMapper (kafka 0.10.2.0 API)";
+ parent.document.title="ValueMapper (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformer.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformer.html b/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformer.html
index df397ec..c61c464 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformer.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>ValueTransformer (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>ValueTransformer (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ValueTransformer (kafka 0.10.2.0 API)";
+ parent.document.title="ValueTransformer (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformerSupplier.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformerSupplier.html b/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformerSupplier.html
index 61d6349..67ea946 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformerSupplier.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/ValueTransformerSupplier.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>ValueTransformerSupplier (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>ValueTransformerSupplier (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ValueTransformerSupplier (kafka 0.10.2.0 API)";
+ parent.document.title="ValueTransformerSupplier (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Window.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Window.html b/0102/javadoc/org/apache/kafka/streams/kstream/Window.html
index f63b51b..3d1b640 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Window.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Window.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Window (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>Window (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Window (kafka 0.10.2.0 API)";
+ parent.document.title="Window (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Windowed.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Windowed.html b/0102/javadoc/org/apache/kafka/streams/kstream/Windowed.html
index 71377d3..e739b7d 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Windowed.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Windowed.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Windowed (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>Windowed (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Windowed (kafka 0.10.2.0 API)";
+ parent.document.title="Windowed (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/Windows.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/Windows.html b/0102/javadoc/org/apache/kafka/streams/kstream/Windows.html
index 8b00276..c709cfc 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/Windows.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/Windows.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:18 PST 2017 -->
-<title>Windows (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>Windows (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Windows (kafka 0.10.2.0 API)";
+ parent.document.title="Windows (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/package-frame.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/package-frame.html b/0102/javadoc/org/apache/kafka/streams/kstream/package-frame.html
index 1d8dbae..d44469c 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/package-frame.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/package-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:19 PST 2017 -->
-<title>org.apache.kafka.streams.kstream (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>org.apache.kafka.streams.kstream (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/package-summary.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/package-summary.html b/0102/javadoc/org/apache/kafka/streams/kstream/package-summary.html
index 0bb5d58..28dbc40 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/package-summary.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/package-summary.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:19 PST 2017 -->
-<title>org.apache.kafka.streams.kstream (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>org.apache.kafka.streams.kstream (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.streams.kstream (kafka 0.10.2.0 API)";
+ parent.document.title="org.apache.kafka.streams.kstream (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/kstream/package-tree.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/kstream/package-tree.html b/0102/javadoc/org/apache/kafka/streams/kstream/package-tree.html
index b0cca8f..26119b1 100644
--- a/0102/javadoc/org/apache/kafka/streams/kstream/package-tree.html
+++ b/0102/javadoc/org/apache/kafka/streams/kstream/package-tree.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:19 PST 2017 -->
-<title>org.apache.kafka.streams.kstream Class Hierarchy (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>org.apache.kafka.streams.kstream Class Hierarchy (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.streams.kstream Class Hierarchy (kafka 0.10.2.0 API)";
+ parent.document.title="org.apache.kafka.streams.kstream Class Hierarchy (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/package-frame.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/package-frame.html b/0102/javadoc/org/apache/kafka/streams/package-frame.html
index b91a23a..cfa4676 100644
--- a/0102/javadoc/org/apache/kafka/streams/package-frame.html
+++ b/0102/javadoc/org/apache/kafka/streams/package-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:19 PST 2017 -->
-<title>org.apache.kafka.streams (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>org.apache.kafka.streams (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/package-summary.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/package-summary.html b/0102/javadoc/org/apache/kafka/streams/package-summary.html
index 0552166..20d878c 100644
--- a/0102/javadoc/org/apache/kafka/streams/package-summary.html
+++ b/0102/javadoc/org/apache/kafka/streams/package-summary.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:19 PST 2017 -->
-<title>org.apache.kafka.streams (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>org.apache.kafka.streams (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.streams (kafka 0.10.2.0 API)";
+ parent.document.title="org.apache.kafka.streams (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/package-tree.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/package-tree.html b/0102/javadoc/org/apache/kafka/streams/package-tree.html
index d228cfa..f5b05cf 100644
--- a/0102/javadoc/org/apache/kafka/streams/package-tree.html
+++ b/0102/javadoc/org/apache/kafka/streams/package-tree.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:19 PST 2017 -->
-<title>org.apache.kafka.streams Class Hierarchy (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:35 PDT 2017 -->
+<title>org.apache.kafka.streams Class Hierarchy (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.streams Class Hierarchy (kafka 0.10.2.0 API)";
+ parent.document.title="org.apache.kafka.streams Class Hierarchy (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/AbstractProcessor.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/AbstractProcessor.html b/0102/javadoc/org/apache/kafka/streams/processor/AbstractProcessor.html
index 5a47dee..a1c69b4 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/AbstractProcessor.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/AbstractProcessor.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>AbstractProcessor (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>AbstractProcessor (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="AbstractProcessor (kafka 0.10.2.0 API)";
+ parent.document.title="AbstractProcessor (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/DefaultPartitionGrouper.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/DefaultPartitionGrouper.html b/0102/javadoc/org/apache/kafka/streams/processor/DefaultPartitionGrouper.html
index 22a4c4a..6c5526e 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/DefaultPartitionGrouper.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/DefaultPartitionGrouper.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>DefaultPartitionGrouper (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>DefaultPartitionGrouper (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="DefaultPartitionGrouper (kafka 0.10.2.0 API)";
+ parent.document.title="DefaultPartitionGrouper (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.html b/0102/javadoc/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.html
index 4bedb7b..d75ed36 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>FailOnInvalidTimestamp (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>FailOnInvalidTimestamp (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="FailOnInvalidTimestamp (kafka 0.10.2.0 API)";
+ parent.document.title="FailOnInvalidTimestamp (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.html b/0102/javadoc/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.html
index a288ce5..9eb611e 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>LogAndSkipOnInvalidTimestamp (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>LogAndSkipOnInvalidTimestamp (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="LogAndSkipOnInvalidTimestamp (kafka 0.10.2.0 API)";
+ parent.document.title="LogAndSkipOnInvalidTimestamp (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/PartitionGrouper.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/PartitionGrouper.html b/0102/javadoc/org/apache/kafka/streams/processor/PartitionGrouper.html
index f9929a3..81082ac 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/PartitionGrouper.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/PartitionGrouper.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>PartitionGrouper (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>PartitionGrouper (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="PartitionGrouper (kafka 0.10.2.0 API)";
+ parent.document.title="PartitionGrouper (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/Processor.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/Processor.html b/0102/javadoc/org/apache/kafka/streams/processor/Processor.html
index 25d9ff2..859d507 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/Processor.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/Processor.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>Processor (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>Processor (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Processor (kafka 0.10.2.0 API)";
+ parent.document.title="Processor (kafka 0.10.2.1 API)";
}
//-->
</script>
@@ -202,7 +202,9 @@
<h4>close</h4>
<pre>void close()</pre>
<div class="block">Close this processor and clean up any resources. Be aware that <a href="../../../../../org/apache/kafka/streams/processor/Processor.html#close()"><code>close()</code></a> is called after an internal cleanup.
- Thus, it is not possible to write anything to Kafka as underlying clients are already closed.</div>
+ Thus, it is not possible to write anything to Kafka as underlying clients are already closed.
+ <p>
+ Note: Do not close any streams managed resources, like <a href="../../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s here, as they are managed by the library.</div>
</li>
</ul>
</li>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html b/0102/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html
index bc96cf5..f81dc59 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>ProcessorContext (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>ProcessorContext (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ProcessorContext (kafka 0.10.2.0 API)";
+ parent.document.title="ProcessorContext (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/ProcessorSupplier.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/ProcessorSupplier.html b/0102/javadoc/org/apache/kafka/streams/processor/ProcessorSupplier.html
index 4c1becc..c855d04 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/ProcessorSupplier.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/ProcessorSupplier.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>ProcessorSupplier (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>ProcessorSupplier (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ProcessorSupplier (kafka 0.10.2.0 API)";
+ parent.document.title="ProcessorSupplier (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/StateRestoreCallback.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/StateRestoreCallback.html b/0102/javadoc/org/apache/kafka/streams/processor/StateRestoreCallback.html
index 2659866..fa537b3 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/StateRestoreCallback.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/StateRestoreCallback.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>StateRestoreCallback (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>StateRestoreCallback (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="StateRestoreCallback (kafka 0.10.2.0 API)";
+ parent.document.title="StateRestoreCallback (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/StateStore.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/StateStore.html b/0102/javadoc/org/apache/kafka/streams/processor/StateStore.html
index a67d13c..b342fd7 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/StateStore.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/StateStore.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>StateStore (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>StateStore (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="StateStore (kafka 0.10.2.0 API)";
+ parent.document.title="StateStore (kafka 0.10.2.1 API)";
}
//-->
</script>
@@ -211,7 +211,10 @@
<pre>void close()</pre>
<div class="block">Close the storage engine.
Note that this function needs to be idempotent since it may be called
- several times on the same state store.</div>
+ several times on the same state store.
+ <p>
+ Users only need to implement this function but should NEVER need to call this api explicitly
+ as it will be called by the library automatically when necessary</div>
</li>
</ul>
<a name="persistent()">
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/StateStoreSupplier.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/StateStoreSupplier.html b/0102/javadoc/org/apache/kafka/streams/processor/StateStoreSupplier.html
index 13a06ca..656947d 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/StateStoreSupplier.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/StateStoreSupplier.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>StateStoreSupplier (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>StateStoreSupplier (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="StateStoreSupplier (kafka 0.10.2.0 API)";
+ parent.document.title="StateStoreSupplier (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/StreamPartitioner.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/StreamPartitioner.html b/0102/javadoc/org/apache/kafka/streams/processor/StreamPartitioner.html
index b04648d..170cdf8 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/StreamPartitioner.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/StreamPartitioner.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>StreamPartitioner (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>StreamPartitioner (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="StreamPartitioner (kafka 0.10.2.0 API)";
+ parent.document.title="StreamPartitioner (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/TaskId.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/TaskId.html b/0102/javadoc/org/apache/kafka/streams/processor/TaskId.html
index 43b4232..292057f 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/TaskId.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/TaskId.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>TaskId (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TaskId (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TaskId (kafka 0.10.2.0 API)";
+ parent.document.title="TaskId (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/TimestampExtractor.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/TimestampExtractor.html b/0102/javadoc/org/apache/kafka/streams/processor/TimestampExtractor.html
index 167bab7..8299280 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/TimestampExtractor.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/TimestampExtractor.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>TimestampExtractor (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TimestampExtractor (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TimestampExtractor (kafka 0.10.2.0 API)";
+ parent.document.title="TimestampExtractor (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.AutoOffsetReset.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.AutoOffsetReset.html b/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.AutoOffsetReset.html
index 0825b30..cd322c5 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.AutoOffsetReset.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.AutoOffsetReset.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>TopologyBuilder.AutoOffsetReset (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TopologyBuilder.AutoOffsetReset (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TopologyBuilder.AutoOffsetReset (kafka 0.10.2.0 API)";
+ parent.document.title="TopologyBuilder.AutoOffsetReset (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html b/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html
index 9934f8c..b64430b 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>TopologyBuilder.TopicsInfo (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TopologyBuilder.TopicsInfo (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TopologyBuilder.TopicsInfo (kafka 0.10.2.0 API)";
+ parent.document.title="TopologyBuilder.TopicsInfo (kafka 0.10.2.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html
----------------------------------------------------------------------
diff --git a/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html b/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html
index bc7caf5..e40f47e 100644
--- a/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html
+++ b/0102/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Feb 14 09:29:17 PST 2017 -->
-<title>TopologyBuilder (kafka 0.10.2.0 API)</title>
-<meta name="date" content="2017-02-14">
+<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 07 15:08:34 PDT 2017 -->
+<title>TopologyBuilder (kafka 0.10.2.1 API)</title>
+<meta name="date" content="2017-04-07">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TopologyBuilder (kafka 0.10.2.0 API)";
+ parent.document.title="TopologyBuilder (kafka 0.10.2.1 API)";
}
//-->
</script>