You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rs...@apache.org on 2017/11/17 14:46:35 UTC
[04/51] [partial] kafka-site git commit: Update site for 0.11.0.2
release
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html b/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html
index cba1009..68c22d9 100644
--- a/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html
+++ b/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 -->
-<title>CreateTopicPolicy.RequestMetadata (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:18 GMT 2017 -->
+<title>CreateTopicPolicy.RequestMetadata (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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="CreateTopicPolicy.RequestMetadata (kafka 0.11.0.1 API)";
+ parent.document.title="CreateTopicPolicy.RequestMetadata (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -83,7 +83,7 @@
</div>
<div class="contentContainer">
<ul class="inheritance">
-<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li>
+<li>java.lang.Object</li>
<li>
<ul class="inheritance">
<li>org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata</li>
@@ -100,7 +100,7 @@
<hr>
<br>
<pre>public static class <span class="strong">CreateTopicPolicy.RequestMetadata</span>
-extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></pre>
+extends java.lang.Object</pre>
<div class="block">Class containing the create request parameters.</div>
</li>
</ul>
@@ -120,11 +120,11 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#CreateTopicPolicy.RequestMetadata(java.lang.String,%20java.lang.Integer,%20java.lang.Short,%20java.util.Map,%20java.util.Map)">CreateTopicPolicy.RequestMetadata</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a> numPartitions,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Short.html?is-external=true" title="class or interface in java.lang">Short</a> replicationFactor,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>>> replicasAssignments,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> configs)</code>
+<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#CreateTopicPolicy.RequestMetadata(java.lang.String,%20java.lang.Integer,%20java.lang.Short,%20java.util.Map,%20java.util.Map)">CreateTopicPolicy.RequestMetadata</a></strong>(java.lang.String topic,
+ java.lang.Integer numPartitions,
+ java.lang.Short replicationFactor,
+ java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> replicasAssignments,
+ java.util.Map<java.lang.String,java.lang.String> configs)</code>
<div class="block">Create an instance of this class with the provided parameters.</div>
</td>
</tr>
@@ -144,38 +144,38 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>></code></td>
+<td class="colFirst"><code>java.util.Map<java.lang.String,java.lang.String></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#configs()">configs</a></strong>()</code>
<div class="block">Return topic configs in the request, not including broker defaults.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a></code></td>
+<td class="colFirst"><code>java.lang.Integer</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#numPartitions()">numPartitions</a></strong>()</code>
<div class="block">Return the number of partitions to create or null if replicaAssignments is not null.</div>
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>>></code></td>
+<td class="colFirst"><code>java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#replicasAssignments()">replicasAssignments</a></strong>()</code>
<div class="block">Return a map from partition id to replica (broker) ids or null if numPartitions and replicationFactor are
set instead.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Short.html?is-external=true" title="class or interface in java.lang">Short</a></code></td>
+<td class="colFirst"><code>java.lang.Short</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#replicationFactor()">replicationFactor</a></strong>()</code>
<div class="block">Return the number of replicas to create or null if replicaAssignments is not null.</div>
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
+<td class="colFirst"><code>java.lang.String</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#topic()">topic</a></strong>()</code>
<div class="block">Return the name of the topic to create.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
+<td class="colFirst"><code>java.lang.String</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html#toString()">toString</a></strong>()</code> </td>
</tr>
</table>
@@ -183,8 +183,8 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">
<!-- -->
</a>
-<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3>
-<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang
/Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li>
+<h3>Methods inherited from class java.lang.Object</h3>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait</code></li>
</ul>
</li>
</ul>
@@ -206,11 +206,11 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockListLast">
<li class="blockList">
<h4>CreateTopicPolicy.RequestMetadata</h4>
-<pre>public CreateTopicPolicy.RequestMetadata(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a> numPartitions,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Short.html?is-external=true" title="class or interface in java.lang">Short</a> replicationFactor,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>>> replicasAssignments,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> configs)</pre>
+<pre>public CreateTopicPolicy.RequestMetadata(java.lang.String topic,
+ java.lang.Integer numPartitions,
+ java.lang.Short replicationFactor,
+ java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> replicasAssignments,
+ java.util.Map<java.lang.String,java.lang.String> configs)</pre>
<div class="block">Create an instance of this class with the provided parameters.
This constructor is public to make testing of <code>CreateTopicPolicy</code> implementations easier.</div>
@@ -233,7 +233,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>topic</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic()</pre>
+<pre>public java.lang.String topic()</pre>
<div class="block">Return the name of the topic to create.</div>
</li>
</ul>
@@ -243,7 +243,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>numPartitions</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a> numPartitions()</pre>
+<pre>public java.lang.Integer numPartitions()</pre>
<div class="block">Return the number of partitions to create or null if replicaAssignments is not null.</div>
</li>
</ul>
@@ -253,7 +253,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>replicationFactor</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Short.html?is-external=true" title="class or interface in java.lang">Short</a> replicationFactor()</pre>
+<pre>public java.lang.Short replicationFactor()</pre>
<div class="block">Return the number of replicas to create or null if replicaAssignments is not null.</div>
</li>
</ul>
@@ -263,7 +263,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>replicasAssignments</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>>> replicasAssignments()</pre>
+<pre>public java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> replicasAssignments()</pre>
<div class="block">Return a map from partition id to replica (broker) ids or null if numPartitions and replicationFactor are
set instead.</div>
</li>
@@ -274,7 +274,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>configs</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> configs()</pre>
+<pre>public java.util.Map<java.lang.String,java.lang.String> configs()</pre>
<div class="block">Return topic configs in the request, not including broker defaults. Broker configs are passed via
the <code>configure()</code> method of the policy implementation.</div>
</li>
@@ -285,10 +285,10 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockListLast">
<li class="blockList">
<h4>toString</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> toString()</pre>
+<pre>public java.lang.String toString()</pre>
<dl>
<dt><strong>Overrides:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a></code> in class <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></code></dd>
+<dd><code>toString</code> in class <code>java.lang.Object</code></dd>
</dl>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.html b/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.html
index 397bf8d..49681cd 100644
--- a/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.html
+++ b/0110/javadoc/org/apache/kafka/server/policy/CreateTopicPolicy.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 -->
-<title>CreateTopicPolicy (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:18 GMT 2017 -->
+<title>CreateTopicPolicy (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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="CreateTopicPolicy (kafka 0.11.0.1 API)";
+ parent.document.title="CreateTopicPolicy (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -87,12 +87,12 @@
<li class="blockList">
<dl>
<dt>All Superinterfaces:</dt>
-<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>, <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a></dd>
+<dd>java.lang.AutoCloseable, <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a></dd>
</dl>
<hr>
<br>
<pre>public interface <span class="strong">CreateTopicPolicy</span>
-extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a></pre>
+extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a>, java.lang.AutoCloseable</pre>
<div class="block">An interface for enforcing a policy on create topics requests.
Common use cases are requiring that the replication factor, min.insync.replicas and/or retention settings for a
@@ -159,8 +159,8 @@ extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title
<li class="blockList"><a name="methods_inherited_from_class_java.lang.AutoCloseable">
<!-- -->
</a>
-<h3>Methods inherited from interface java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a></h3>
-<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true#close()" title="class or interface in java.lang">close</a></code></li>
+<h3>Methods inherited from interface java.lang.AutoCloseable</h3>
+<code>close</code></li>
</ul>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/server/policy/package-frame.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/server/policy/package-frame.html b/0110/javadoc/org/apache/kafka/server/policy/package-frame.html
index 8010242..fb795d8 100644
--- a/0110/javadoc/org/apache/kafka/server/policy/package-frame.html
+++ b/0110/javadoc/org/apache/kafka/server/policy/package-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:59 BST 2017 -->
-<title>org.apache.kafka.server.policy (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 -->
+<title>org.apache.kafka.server.policy (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/server/policy/package-summary.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/server/policy/package-summary.html b/0110/javadoc/org/apache/kafka/server/policy/package-summary.html
index aeb71f2..eb76e49 100644
--- a/0110/javadoc/org/apache/kafka/server/policy/package-summary.html
+++ b/0110/javadoc/org/apache/kafka/server/policy/package-summary.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:59 BST 2017 -->
-<title>org.apache.kafka.server.policy (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 -->
+<title>org.apache.kafka.server.policy (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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.server.policy (kafka 0.11.0.1 API)";
+ parent.document.title="org.apache.kafka.server.policy (kafka 0.11.0.2 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/server/policy/package-tree.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/server/policy/package-tree.html b/0110/javadoc/org/apache/kafka/server/policy/package-tree.html
index 9a19eb3..33e6a58 100644
--- a/0110/javadoc/org/apache/kafka/server/policy/package-tree.html
+++ b/0110/javadoc/org/apache/kafka/server/policy/package-tree.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:59 BST 2017 -->
-<title>org.apache.kafka.server.policy Class Hierarchy (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 -->
+<title>org.apache.kafka.server.policy Class Hierarchy (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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.server.policy Class Hierarchy (kafka 0.11.0.1 API)";
+ parent.document.title="org.apache.kafka.server.policy Class Hierarchy (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -71,7 +71,7 @@
<div class="contentContainer">
<h2 title="Class Hierarchy">Class Hierarchy</h2>
<ul>
-<li type="circle">java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang"><span class="strong">Object</span></a>
+<li type="circle">java.lang.Object
<ul>
<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/AlterConfigPolicy.RequestMetadata.html" title="class in org.apache.kafka.server.policy"><span class="strong">AlterConfigPolicy.RequestMetadata</span></a></li>
<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.RequestMetadata.html" title="class in org.apache.kafka.server.policy"><span class="strong">CreateTopicPolicy.RequestMetadata</span></a></li>
@@ -80,7 +80,7 @@
</ul>
<h2 title="Interface Hierarchy">Interface Hierarchy</h2>
<ul>
-<li type="circle">java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang"><span class="strong">AutoCloseable</span></a>
+<li type="circle">java.lang.AutoCloseable
<ul>
<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/AlterConfigPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">AlterConfigPolicy</span></a> (also extends org.apache.kafka.common.<a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a>)</li>
<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">CreateTopicPolicy</span></a> (also extends org.apache.kafka.common.<a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a>)</li>
@@ -88,8 +88,8 @@
</li>
<li type="circle">org.apache.kafka.common.<a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common"><span class="strong">Configurable</span></a>
<ul>
-<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/AlterConfigPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">AlterConfigPolicy</span></a> (also extends java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>)</li>
-<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">CreateTopicPolicy</span></a> (also extends java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>)</li>
+<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/AlterConfigPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">AlterConfigPolicy</span></a> (also extends java.lang.AutoCloseable)</li>
+<li type="circle">org.apache.kafka.server.policy.<a href="../../../../../org/apache/kafka/server/policy/CreateTopicPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">CreateTopicPolicy</span></a> (also extends java.lang.AutoCloseable)</li>
</ul>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/streams/KafkaClientSupplier.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/streams/KafkaClientSupplier.html b/0110/javadoc/org/apache/kafka/streams/KafkaClientSupplier.html
index eba940c..25f0af7 100644
--- a/0110/javadoc/org/apache/kafka/streams/KafkaClientSupplier.html
+++ b/0110/javadoc/org/apache/kafka/streams/KafkaClientSupplier.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:56 BST 2017 -->
-<title>KafkaClientSupplier (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:17 GMT 2017 -->
+<title>KafkaClientSupplier (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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="KafkaClientSupplier (kafka 0.11.0.1 API)";
+ parent.document.title="KafkaClientSupplier (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -110,19 +110,19 @@
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><byte[],byte[]></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaClientSupplier.html#getConsumer(java.util.Map)">getConsumer</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> config)</code>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaClientSupplier.html#getConsumer(java.util.Map)">getConsumer</a></strong>(java.util.Map<java.lang.String,java.lang.Object> config)</code>
<div class="block">Create a <a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><code>Consumer</code></a> which is used to read records of source topics.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><a href="../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><byte[],byte[]></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaClientSupplier.html#getProducer(java.util.Map)">getProducer</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> config)</code>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaClientSupplier.html#getProducer(java.util.Map)">getProducer</a></strong>(java.util.Map<java.lang.String,java.lang.Object> config)</code>
<div class="block">Create a <a href="../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer"><code>Producer</code></a> which is used to write records to sink topics.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code><a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><byte[],byte[]></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaClientSupplier.html#getRestoreConsumer(java.util.Map)">getRestoreConsumer</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> config)</code>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaClientSupplier.html#getRestoreConsumer(java.util.Map)">getRestoreConsumer</a></strong>(java.util.Map<java.lang.String,java.lang.Object> config)</code>
<div class="block">Create a <a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><code>Consumer</code></a> which is used to read records to restore <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s.</div>
</td>
</tr>
@@ -147,7 +147,7 @@
<ul class="blockList">
<li class="blockList">
<h4>getProducer</h4>
-<pre><a href="../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><byte[],byte[]> getProducer(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> config)</pre>
+<pre><a href="../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><byte[],byte[]> getProducer(java.util.Map<java.lang.String,java.lang.Object> config)</pre>
<div class="block">Create a <a href="../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer"><code>Producer</code></a> which is used to write records to sink topics.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>config</code> - <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#getProducerConfigs(java.lang.String)"><code>producer config</code></a> which is supplied by the
<a href="../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a> given to the <a href="../../../../org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams"><code>KafkaStreams</code></a> instance</dd>
@@ -160,7 +160,7 @@
<ul class="blockList">
<li class="blockList">
<h4>getConsumer</h4>
-<pre><a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><byte[],byte[]> getConsumer(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> config)</pre>
+<pre><a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><byte[],byte[]> getConsumer(java.util.Map<java.lang.String,java.lang.Object> config)</pre>
<div class="block">Create a <a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><code>Consumer</code></a> which is used to read records of source topics.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>config</code> - <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#getConsumerConfigs(StreamThread,%20java.lang.String,%20java.lang.String)"><code>consumer config</code></a> which is
supplied by the <a href="../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a> given to the <a href="../../../../org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams"><code>KafkaStreams</code></a> instance</dd>
@@ -173,7 +173,7 @@
<ul class="blockListLast">
<li class="blockList">
<h4>getRestoreConsumer</h4>
-<pre><a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><byte[],byte[]> getRestoreConsumer(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> config)</pre>
+<pre><a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><byte[],byte[]> getRestoreConsumer(java.util.Map<java.lang.String,java.lang.Object> config)</pre>
<div class="block">Create a <a href="../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><code>Consumer</code></a> which is used to read records to restore <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>config</code> - <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#getRestoreConsumerConfigs(java.lang.String)"><code>restore consumer config</code></a> which is supplied
by the <a href="../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a> given to the <a href="../../../../org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams"><code>KafkaStreams</code></a></dd>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/streams/KafkaStreams.State.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/streams/KafkaStreams.State.html b/0110/javadoc/org/apache/kafka/streams/KafkaStreams.State.html
index 6e61ac0..dee066e 100644
--- a/0110/javadoc/org/apache/kafka/streams/KafkaStreams.State.html
+++ b/0110/javadoc/org/apache/kafka/streams/KafkaStreams.State.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:56 BST 2017 -->
-<title>KafkaStreams.State (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:17 GMT 2017 -->
+<title>KafkaStreams.State (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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="KafkaStreams.State (kafka 0.11.0.1 API)";
+ parent.document.title="KafkaStreams.State (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -83,10 +83,10 @@
</div>
<div class="contentContainer">
<ul class="inheritance">
-<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li>
+<li>java.lang.Object</li>
<li>
<ul class="inheritance">
-<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true" title="class or interface in java.lang">java.lang.Enum</a><<a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a>></li>
+<li>java.lang.Enum<<a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a>></li>
<li>
<ul class="inheritance">
<li>org.apache.kafka.streams.KafkaStreams.State</li>
@@ -100,7 +100,7 @@
<li class="blockList">
<dl>
<dt>All Implemented Interfaces:</dt>
-<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true" title="class or interface in java.io">Serializable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Comparable.html?is-external=true" title="class or interface in java.lang">Comparable</a><<a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a>></dd>
+<dd>java.io.Serializable, java.lang.Comparable<<a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a>></dd>
</dl>
<dl>
<dt>Enclosing class:</dt>
@@ -109,7 +109,7 @@
<hr>
<br>
<pre>public static enum <span class="strong">KafkaStreams.State</span>
-extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true" title="class or interface in java.lang">Enum</a><<a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a>></pre>
+extends java.lang.Enum<<a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a>></pre>
<div class="block">Kafka Streams states are the possible state that a Kafka Streams instance can be in.
An instance must only be in one state at a time.
Note this instance will be in "Rebalancing" state if any of its threads is rebalancing
@@ -214,7 +214,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is
</tr>
<tr class="altColor">
<td class="colFirst"><code>static <a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html#valueOf(java.lang.String)">valueOf</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name)</code>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html#valueOf(java.lang.String)">valueOf</a></strong>(java.lang.String name)</code>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</td>
</tr>
@@ -230,15 +230,15 @@ the order they are declared.</div>
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Enum">
<!-- -->
</a>
-<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true" title="class or interface in java.lang">Enum</a></h3>
-<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#compareTo(E)" title="class or interface in java.lang">compareTo</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#getDeclaringClass()" title="class or interface in java.lang">getDeclaringClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/
api/java/lang/Enum.html?is-external=true#name()" title="class or interface in java.lang">name</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#ordinal()" title="class or interface in java.lang">ordinal</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#toString()" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Enum.html?is-external=true#valueOf(java.lang.Class,%20java.lang.String)" title="class or interface in java.lang">valueOf</a></code></li>
+<h3>Methods inherited from class java.lang.Enum</h3>
+<code>clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf</code></li>
</ul>
<ul class="blockList">
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">
<!-- -->
</a>
-<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3>
-<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li>
+<h3>Methods inherited from class java.lang.Object</h3>
+<code>getClass, notify, notifyAll, wait, wait, wait</code></li>
</ul>
</li>
</ul>
@@ -339,7 +339,7 @@ for (KafkaStreams.State c : KafkaStreams.State.values())
<ul class="blockList">
<li class="blockList">
<h4>valueOf</h4>
-<pre>public static <a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a> valueOf(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> name)</pre>
+<pre>public static <a href="../../../../org/apache/kafka/streams/KafkaStreams.State.html" title="enum in org.apache.kafka.streams">KafkaStreams.State</a> valueOf(java.lang.String name)</pre>
<div class="block">Returns the enum constant of this type with the specified name.
The string must match <i>exactly</i> an identifier used to declare an
enum constant in this type. (Extraneous whitespace characters are
@@ -347,8 +347,8 @@ not permitted.)</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>name</code> - the name of the enum constant to be returned.</dd>
<dt><span class="strong">Returns:</span></dt><dd>the enum constant with the specified name</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true" title="class or interface in java.lang">IllegalArgumentException</a></code> - if this enum type has no constant with the specified name</dd>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/NullPointerException.html?is-external=true" title="class or interface in java.lang">NullPointerException</a></code> - if the argument is null</dd></dl>
+<dd><code>java.lang.IllegalArgumentException</code> - if this enum type has no constant with the specified name</dd>
+<dd><code>java.lang.NullPointerException</code> - if the argument is null</dd></dl>
</li>
</ul>
<a name="isRunning()">
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html b/0110/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html
index 3fdae67..b057fc7 100644
--- a/0110/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html
+++ b/0110/javadoc/org/apache/kafka/streams/KafkaStreams.StateListener.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:56 BST 2017 -->
-<title>KafkaStreams.StateListener (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:17 GMT 2017 -->
+<title>KafkaStreams.StateListener (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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="KafkaStreams.StateListener (kafka 0.11.0.1 API)";
+ parent.document.title="KafkaStreams.StateListener (kafka 0.11.0.2 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/streams/KafkaStreams.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/streams/KafkaStreams.html b/0110/javadoc/org/apache/kafka/streams/KafkaStreams.html
index 7796368..52b9c17 100644
--- a/0110/javadoc/org/apache/kafka/streams/KafkaStreams.html
+++ b/0110/javadoc/org/apache/kafka/streams/KafkaStreams.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:56 BST 2017 -->
-<title>KafkaStreams (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:17 GMT 2017 -->
+<title>KafkaStreams (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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="KafkaStreams (kafka 0.11.0.1 API)";
+ parent.document.title="KafkaStreams (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -83,7 +83,7 @@
</div>
<div class="contentContainer">
<ul class="inheritance">
-<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li>
+<li>java.lang.Object</li>
<li>
<ul class="inheritance">
<li>org.apache.kafka.streams.KafkaStreams</li>
@@ -97,7 +97,7 @@
<br>
<pre><a href="../../../../org/apache/kafka/common/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.kafka.common.annotation">@InterfaceStability.Evolving</a>
public class <span class="strong">KafkaStreams</span>
-extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></pre>
+extends java.lang.Object</pre>
<div class="block">A Kafka client that allows for performing continuous computation on input coming from one or more input topics and
sends output to zero, one, or more output topics.
<p>
@@ -179,7 +179,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
</tr>
<tr class="altColor">
<td class="colOne"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#KafkaStreams(org.apache.kafka.streams.processor.TopologyBuilder,%20java.util.Properties)">KafkaStreams</a></strong>(<a href="../../../../org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a> builder,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true" title="class or interface in java.util">Properties</a> props)</code>
+ java.util.Properties props)</code>
<div class="block">Create a <code>KafkaStreams</code> instance.</div>
</td>
</tr>
@@ -212,7 +212,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>></code></td>
+<td class="colFirst"><code>java.util.Collection<<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#allMetadata()">allMetadata</a></strong>()</code>
<div class="block">Find all currently running <code>KafkaStreams</code> instances (potentially remotely) that use the same
<a href="../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>application ID</code></a> as this instance (i.e., all instances that belong to
@@ -220,8 +220,8 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#allMetadataForStore(java.lang.String)">allMetadataForStore</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName)</code>
+<td class="colFirst"><code>java.util.Collection<<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>></code></td>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#allMetadataForStore(java.lang.String)">allMetadataForStore</a></strong>(java.lang.String storeName)</code>
<div class="block">Find all currently running <code>KafkaStreams</code> instances (potentially remotely) that
use the same <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>application ID</code></a> as this instance (i.e., all
@@ -247,14 +247,14 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<tr class="altColor">
<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#close(long,%20java.util.concurrent.TimeUnit)">close</a></strong>(long timeout,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="class or interface in java.util.concurrent">TimeUnit</a> timeUnit)</code>
+ java.util.concurrent.TimeUnit timeUnit)</code>
<div class="block">Shutdown this <code>KafkaStreams</code> by signaling all the threads to stop, and then wait up to the timeout for the
threads to join.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code><K> <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#metadataForKey(java.lang.String,%20K,%20org.apache.kafka.common.serialization.Serializer)">metadataForKey</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName,
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#metadataForKey(java.lang.String,%20K,%20org.apache.kafka.common.serialization.Serializer)">metadataForKey</a></strong>(java.lang.String storeName,
K key,
<a href="../../../../org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization">Serializer</a><K> keySerializer)</code>
<div class="block">Find the currently running <code>KafkaStreams</code> instance (potentially remotely) that
@@ -269,7 +269,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
</tr>
<tr class="altColor">
<td class="colFirst"><code><K> <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#metadataForKey(java.lang.String,%20K,%20org.apache.kafka.streams.processor.StreamPartitioner)">metadataForKey</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName,
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#metadataForKey(java.lang.String,%20K,%20org.apache.kafka.streams.processor.StreamPartitioner)">metadataForKey</a></strong>(java.lang.String storeName,
K key,
<a href="../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a><? super K,?> partitioner)</code>
<div class="block">Find the currently running <code>KafkaStreams</code> instance (potentially remotely) that
@@ -283,7 +283,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>></code></td>
+<td class="colFirst"><code>java.util.Map<<a href="../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#metrics()">metrics</a></strong>()</code>
<div class="block">Get read-only handle on global metrics registry.</div>
</td>
@@ -296,7 +296,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)">setUncaughtExceptionHandler</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true" title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> eh)</code>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)">setUncaughtExceptionHandler</a></strong>(java.lang.Thread.UncaughtExceptionHandler eh)</code>
<div class="block">Set the handler invoked when a <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#NUM_STREAM_THREADS_CONFIG"><code>internal thread</code></a> abruptly
terminates due to an uncaught exception.</div>
</td>
@@ -315,22 +315,22 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
</tr>
<tr class="altColor">
<td class="colFirst"><code><T> T</code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#store(java.lang.String,%20org.apache.kafka.streams.state.QueryableStoreType)">store</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName,
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#store(java.lang.String,%20org.apache.kafka.streams.state.QueryableStoreType)">store</a></strong>(java.lang.String storeName,
<a href="../../../../org/apache/kafka/streams/state/QueryableStoreType.html" title="interface in org.apache.kafka.streams.state">QueryableStoreType</a><T> queryableStoreType)</code>
<div class="block">Get a facade wrapping the local <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a> instances with the provided <code>storeName</code> if the Store's
type is accepted by the provided <a href="../../../../org/apache/kafka/streams/state/QueryableStoreType.html#accepts(org.apache.kafka.streams.processor.StateStore)"><code>queryableStoreType</code></a>.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
+<td class="colFirst"><code>java.lang.String</code></td>
<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#toString()">toString</a></strong>()</code>
<div class="block">Produce a string representation containing useful information about this <code>KafkaStream</code> instance such as
thread IDs, task IDs, and a representation of the topology DAG including <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s (cf.</div>
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td>
-<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#toString(java.lang.String)">toString</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> indent)</code>
+<td class="colFirst"><code>java.lang.String</code></td>
+<td class="colLast"><code><strong><a href="../../../../org/apache/kafka/streams/KafkaStreams.html#toString(java.lang.String)">toString</a></strong>(java.lang.String indent)</code>
<div class="block">Produce a string representation containing useful information about this <code>KafkaStream</code> instance such as
thread IDs, task IDs, and a representation of the topology DAG including <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s (cf.</div>
</td>
@@ -340,8 +340,8 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">
<!-- -->
</a>
-<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3>
-<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang
/Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li>
+<h3>Methods inherited from class java.lang.Object</h3>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait</code></li>
</ul>
</li>
</ul>
@@ -364,7 +364,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<li class="blockList">
<h4>KafkaStreams</h4>
<pre>public KafkaStreams(<a href="../../../../org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a> builder,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true" title="class or interface in java.util">Properties</a> props)</pre>
+ java.util.Properties props)</pre>
<div class="block">Create a <code>KafkaStreams</code> instance.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>builder</code> - the processor topology builder specifying the computational logic</dd><dd><code>props</code> - properties for <a href="../../../../org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams"><code>StreamsConfig</code></a></dd></dl>
</li>
@@ -431,7 +431,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>metrics</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre>
+<pre>public java.util.Map<<a href="../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre>
<div class="block">Get read-only handle on global metrics registry.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>Map of all metrics.</dd></dl>
</li>
@@ -443,7 +443,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<li class="blockList">
<h4>start</h4>
<pre>public void start()
- throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalStateException.html?is-external=true" title="class or interface in java.lang">IllegalStateException</a>,
+ throws java.lang.IllegalStateException,
<a href="../../../../org/apache/kafka/streams/errors/StreamsException.html" title="class in org.apache.kafka.streams.errors">StreamsException</a></pre>
<div class="block">Start the <code>KafkaStreams</code> instance by starting all its threads.
<p>
@@ -451,7 +451,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
There will be no error and the client will hang and retry to verify the broker version until it
<a href="../../../../org/apache/kafka/streams/StreamsConfig.html#REQUEST_TIMEOUT_MS_CONFIG"><code>times out</code></a>.</div>
<dl><dt><span class="strong">Throws:</span></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalStateException.html?is-external=true" title="class or interface in java.lang">IllegalStateException</a></code> - if process was already started</dd>
+<dd><code>java.lang.IllegalStateException</code> - if process was already started</dd>
<dd><code><a href="../../../../org/apache/kafka/streams/errors/StreamsException.html" title="class in org.apache.kafka.streams.errors">StreamsException</a></code> - if the Kafka brokers have version 0.10.0.x</dd></dl>
</li>
</ul>
@@ -473,7 +473,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<li class="blockList">
<h4>close</h4>
<pre>public boolean close(long timeout,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="class or interface in java.util.concurrent">TimeUnit</a> timeUnit)</pre>
+ java.util.concurrent.TimeUnit timeUnit)</pre>
<div class="block">Shutdown this <code>KafkaStreams</code> by signaling all the threads to stop, and then wait up to the timeout for the
threads to join.
A <code>timeout</code> of 0 means to wait forever.</div>
@@ -489,13 +489,13 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>toString</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> toString()</pre>
+<pre>public java.lang.String toString()</pre>
<div class="block">Produce a string representation containing useful information about this <code>KafkaStream</code> instance such as
thread IDs, task IDs, and a representation of the topology DAG including <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s (cf.
<a href="../../../../org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor"><code>TopologyBuilder</code></a> and <a href="../../../../org/apache/kafka/streams/kstream/KStreamBuilder.html" title="class in org.apache.kafka.streams.kstream"><code>KStreamBuilder</code></a>).</div>
<dl>
<dt><strong>Overrides:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a></code> in class <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></code></dd>
+<dd><code>toString</code> in class <code>java.lang.Object</code></dd>
<dt><span class="strong">Returns:</span></dt><dd>A string representation of the Kafka Streams instance.</dd></dl>
</li>
</ul>
@@ -505,7 +505,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>toString</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> toString(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> indent)</pre>
+<pre>public java.lang.String toString(java.lang.String indent)</pre>
<div class="block">Produce a string representation containing useful information about this <code>KafkaStream</code> instance such as
thread IDs, task IDs, and a representation of the topology DAG including <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s (cf.
<a href="../../../../org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor"><code>TopologyBuilder</code></a> and <a href="../../../../org/apache/kafka/streams/kstream/KStreamBuilder.html" title="class in org.apache.kafka.streams.kstream"><code>KStreamBuilder</code></a>).</div>
@@ -528,7 +528,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<p>
Calling this method triggers a restore of local <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s on the next <a href="../../../../org/apache/kafka/streams/KafkaStreams.html#start()"><code>application start</code></a>.</div>
<dl><dt><span class="strong">Throws:</span></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalStateException.html?is-external=true" title="class or interface in java.lang">IllegalStateException</a></code> - if the instance is currently running</dd></dl>
+<dd><code>java.lang.IllegalStateException</code> - if the instance is currently running</dd></dl>
</li>
</ul>
<a name="setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)">
@@ -537,7 +537,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>setUncaughtExceptionHandler</h4>
-<pre>public void setUncaughtExceptionHandler(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true" title="class or interface in java.lang">Thread.UncaughtExceptionHandler</a> eh)</pre>
+<pre>public void setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler eh)</pre>
<div class="block">Set the handler invoked when a <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#NUM_STREAM_THREADS_CONFIG"><code>internal thread</code></a> abruptly
terminates due to an uncaught exception.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>eh</code> - the uncaught exception handler for all internal threads; <code>null</code> deletes the current handler</dd></dl>
@@ -549,7 +549,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>allMetadata</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>> allMetadata()</pre>
+<pre>public java.util.Collection<<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>> allMetadata()</pre>
<div class="block">Find all currently running <code>KafkaStreams</code> instances (potentially remotely) that use the same
<a href="../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>application ID</code></a> as this instance (i.e., all instances that belong to
the same Kafka Streams application) and return <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state"><code>StreamsMetadata</code></a> for each discovered instance.
@@ -564,7 +564,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>allMetadataForStore</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>> allMetadataForStore(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName)</pre>
+<pre>public java.util.Collection<<a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a>> allMetadataForStore(java.lang.String storeName)</pre>
<div class="block">Find all currently running <code>KafkaStreams</code> instances (potentially remotely) that
<ul>
<li>use the same <a href="../../../../org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>application ID</code></a> as this instance (i.e., all
@@ -587,7 +587,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>metadataForKey</h4>
-<pre>public <K> <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a> metadataForKey(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName,
+<pre>public <K> <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a> metadataForKey(java.lang.String storeName,
K key,
<a href="../../../../org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization">Serializer</a><K> keySerializer)</pre>
<div class="block">Find the currently running <code>KafkaStreams</code> instance (potentially remotely) that
@@ -627,7 +627,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockList">
<li class="blockList">
<h4>metadataForKey</h4>
-<pre>public <K> <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a> metadataForKey(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName,
+<pre>public <K> <a href="../../../../org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state">StreamsMetadata</a> metadataForKey(java.lang.String storeName,
K key,
<a href="../../../../org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor">StreamPartitioner</a><? super K,?> partitioner)</pre>
<div class="block">Find the currently running <code>KafkaStreams</code> instance (potentially remotely) that
@@ -656,7 +656,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?
<ul class="blockListLast">
<li class="blockList">
<h4>store</h4>
-<pre>public <T> T store(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> storeName,
+<pre>public <T> T store(java.lang.String storeName,
<a href="../../../../org/apache/kafka/streams/state/QueryableStoreType.html" title="interface in org.apache.kafka.streams.state">QueryableStoreType</a><T> queryableStoreType)</pre>
<div class="block">Get a facade wrapping the local <a href="../../../../org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a> instances with the provided <code>storeName</code> if the Store's
type is accepted by the provided <a href="../../../../org/apache/kafka/streams/state/QueryableStoreType.html#accepts(org.apache.kafka.streams.processor.StateStore)"><code>queryableStoreType</code></a>.