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>.
