http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/deprecated-list.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/deprecated-list.html b/0110/javadoc/deprecated-list.html index 7f6447b..0f4d4ae 100644 --- a/0110/javadoc/deprecated-list.html +++ b/0110/javadoc/deprecated-list.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>Deprecated List (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:20 GMT 2017 --> +<title>Deprecated List (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="Deprecated List (kafka 0.11.0.1 API)"; + parent.document.title="Deprecated List (kafka 0.11.0.2 API)"; } //--> </script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/help-doc.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/help-doc.html b/0110/javadoc/help-doc.html index 4d988ce..c76f765 100644 --- a/0110/javadoc/help-doc.html +++ b/0110/javadoc/help-doc.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>API Help (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:20 GMT 2017 --> +<title>API Help (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="API Help (kafka 0.11.0.1 API)"; + parent.document.title="API Help (kafka 0.11.0.2 API)"; } //--> </script> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/index-all.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/index-all.html b/0110/javadoc/index-all.html index 5a660c4..1b7bef2 100644 --- a/0110/javadoc/index-all.html +++ b/0110/javadoc/index-all.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>Index (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:20 GMT 2017 --> +<title>Index (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="Index (kafka 0.11.0.1 API)"; + parent.document.title="Index (kafka 0.11.0.2 API)"; } //--> </script> @@ -3571,11 +3571,11 @@ </dd> <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Properties)">KafkaConsumer(Properties)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> <dd> -<div class="block">A consumer is instantiated by providing a <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true"; title="class or interface in java.util"><code>Properties</code></a> object as configuration.</div> +<div class="block">A consumer is instantiated by providing a <code>Properties</code> object as configuration.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Properties,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer(Properties, Deserializer<K>, Deserializer<V>)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> <dd> -<div class="block">A consumer is instantiated by providing a <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true"; title="class or interface in java.util"><code>Properties</code></a> object as configuration, and a +<div class="block">A consumer is instantiated by providing a <code>Properties</code> object as configuration, and a key and a value <a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization"><code>Deserializer</code></a>.</div> </dd> <dt><a href="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common"><span class="strong">KafkaException</span></a> - Exception in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt> @@ -7556,7 +7556,7 @@ <dd> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/UnlimitedWindows.html#until(long)">until(long)</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/UnlimitedWindows.html" title="class in org.apache.kafka.streams.kstream">UnlimitedWindows</a></dt> <dd> -<div class="block">Throws an <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true"; title="class or interface in java.lang"><code>IllegalArgumentException</code></a> because the retention time for unlimited windows is always infinite +<div class="block">Throws an <code>IllegalArgumentException</code> because the retention time for unlimited windows is always infinite and cannot be changed.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Windows.html#until(long)">until(long)</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Windows.html" title="class in org.apache.kafka.streams.kstream">Windows</a></dt> @@ -7927,7 +7927,7 @@ the order they are declared.</div> <dd> </dd> <dt><a href="./org/apache/kafka/streams/processor/WallclockTimestampExtractor.html" title="class in org.apache.kafka.streams.processor"><span class="strong">WallclockTimestampExtractor</span></a> - Class in <a href="./org/apache/kafka/streams/processor/package-summary.html">org.apache.kafka.streams.processor</a></dt> <dd> -<div class="block">Retrieves current wall clock timestamps as <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/System.html?is-external=true#currentTimeMillis()" title="class or interface in java.lang"><code>System.currentTimeMillis()</code></a>.</div> +<div class="block">Retrieves current wall clock timestamps as <code>System.currentTimeMillis()</code>.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/processor/WallclockTimestampExtractor.html#WallclockTimestampExtractor()">WallclockTimestampExtractor()</a></span> - Constructor for class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/WallclockTimestampExtractor.html" title="class in org.apache.kafka.streams.processor">WallclockTimestampExtractor</a></dt> <dd> </dd> @@ -7988,7 +7988,7 @@ the order they are declared.</div> </dd> <dt><a href="./org/apache/kafka/streams/state/WindowStoreIterator.html" title="interface in org.apache.kafka.streams.state"><span class="strong">WindowStoreIterator</span></a><<a href="./org/apache/kafka/streams/state/WindowStoreIterator.html" title="type parameter in WindowStoreIterator">V</a>> - Interface in <a href="./org/apache/kafka/streams/state/package-summary.html">org.apache.kafka.streams.state</a></dt> <dd> -<div class="block">Iterator interface of <a href="./org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> with key typed <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang"><code>Long</code></a> used for <a href="./org/apache/kafka/streams/state/ReadOnlyWindowStore.html#fetch(K,%20long,%20long)"><code>ReadOnlyWindowStore.fetch(Object, long, long)</code></a>.</div> +<div class="block">Iterator interface of <a href="./org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams"><code>KeyValue</code></a> with key typed <code>Long</code> used for <a href="./org/apache/kafka/streams/state/ReadOnlyWindowStore.html#fetch(K,%20long,%20long)"><code>ReadOnlyWindowStore.fetch(Object, long, long)</code></a>.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/SessionWindows.html#with(long)">with(long)</a></span> - Static method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/SessionWindows.html" title="class in org.apache.kafka.streams.kstream">SessionWindows</a></dt> <dd> @@ -8008,11 +8008,11 @@ the order they are declared.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html#withByteBufferKeys()">withByteBufferKeys()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></dt> <dd> -<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio"><code>ByteBuffer</code></a>.</div> +<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <code>ByteBuffer</code>.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html#withByteBufferValues()">withByteBufferValues()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state">Stores.ValueFactory</a></dt> <dd> -<div class="block">Use <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio"><code>ByteBuffer</code></a> for values.</div> +<div class="block">Use <code>ByteBuffer</code> for values.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.html#withClientSaslSupport()">withClientSaslSupport()</a></span> - Method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.html" title="class in org.apache.kafka.common.config">ConfigDef</a></dt> <dd> @@ -8024,19 +8024,19 @@ the order they are declared.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html#withDoubleKeys()">withDoubleKeys()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></dt> <dd> -<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Double.html?is-external=true"; title="class or interface in java.lang"><code>Double</code></a>s.</div> +<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <code>Double</code>s.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html#withDoubleValues()">withDoubleValues()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state">Stores.ValueFactory</a></dt> <dd> -<div class="block">Use <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Double.html?is-external=true"; title="class or interface in java.lang"><code>Double</code></a> values.</div> +<div class="block">Use <code>Double</code> values.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html#withIntegerKeys()">withIntegerKeys()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></dt> <dd> -<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang"><code>Integer</code></a>s.</div> +<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <code>Integer</code>s.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html#withIntegerValues()">withIntegerValues()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state">Stores.ValueFactory</a></dt> <dd> -<div class="block">Use <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang"><code>Integer</code></a> values.</div> +<div class="block">Use <code>Integer</code> values.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html#withKeys(java.lang.Class)">withKeys(Class<K>)</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></dt> <dd> @@ -8048,11 +8048,11 @@ the order they are declared.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html#withLongKeys()">withLongKeys()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></dt> <dd> -<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang"><code>Long</code></a>s.</div> +<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <code>Long</code>s.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html#withLongValues()">withLongValues()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state">Stores.ValueFactory</a></dt> <dd> -<div class="block">Use <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang"><code>Long</code></a> values.</div> +<div class="block">Use <code>Long</code> values.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#withPartitions(java.util.Map)">withPartitions(Map<TopicPartition, PartitionInfo>)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt> <dd> @@ -8060,11 +8060,11 @@ the order they are declared.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html#withStringKeys()">withStringKeys()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></dt> <dd> -<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang"><code>String</code></a>s.</div> +<div class="block">Begin to create a <a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><code>KeyValueStore</code></a> by specifying the keys will be <code>String</code>s.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html#withStringValues()">withStringValues()</a></span> - Method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state">Stores.ValueFactory</a></dt> <dd> -<div class="block">Use <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang"><code>String</code></a> values.</div> +<div class="block">Use <code>String</code> values.</div> </dd> <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RetriableCommitFailedException.html#withUnderlyingMessage(java.lang.String)">withUnderlyingMessage(String)</a></span> - Static method in exception org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RetriableCommitFailedException.html" title="class in org.apache.kafka.clients.consumer">RetriableCommitFailedException</a></dt> <dd> </dd> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/index.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/index.html b/0110/javadoc/index.html index 731fccc..5650762 100644 --- a/0110/javadoc/index.html +++ b/0110/javadoc/index.html @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc on Tue Sep 05 19:20:59 BST 2017 --> -<title>kafka 0.11.0.1 API</title> +<!-- Generated by javadoc on Fri Nov 10 23:49:20 GMT 2017 --> +<title>kafka 0.11.0.2 API</title> <script type="text/javascript"> targetPage = "" + window.location.search; if (targetPage != "" && targetPage != "undefined") http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/admin/AdminClient.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/clients/admin/AdminClient.html b/0110/javadoc/org/apache/kafka/clients/admin/AdminClient.html index aae4a1a..837cdfc 100644 --- a/0110/javadoc/org/apache/kafka/clients/admin/AdminClient.html +++ b/0110/javadoc/org/apache/kafka/clients/admin/AdminClient.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:57 BST 2017 --> -<title>AdminClient (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>AdminClient (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="AdminClient (kafka 0.11.0.1 API)"; + parent.document.title="AdminClient (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.clients.admin.AdminClient</li> @@ -95,7 +95,7 @@ <li class="blockList"> <dl> <dt>All Implemented Interfaces:</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></dd> +<dd>java.lang.AutoCloseable</dd> </dl> <dl> <dt>Direct Known Subclasses:</dt> @@ -105,8 +105,8 @@ <br> <pre><a href="../../../../../org/apache/kafka/common/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.kafka.common.annotation">@InterfaceStability.Evolving</a> public abstract class <span class="strong">AdminClient</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> -implements <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 java.lang.Object +implements java.lang.AutoCloseable</pre> <div class="block">The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs. The minimum broker version required is 0.10.0.0. Methods with stricter requirements will specify the minimum broker @@ -152,13 +152,13 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map)">alterConfigs</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="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map)">alterConfigs</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs)</code> <div class="block">Update the configuration for the specified resources with the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map,%20org.apache.kafka.clients.admin.AlterConfigsOptions)">alterConfigs</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="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map,%20org.apache.kafka.clients.admin.AlterConfigsOptions)">alterConfigs</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs, <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsOptions.html" title="class in org.apache.kafka.clients.admin">AlterConfigsOptions</a> options)</code> <div class="block">Update the configuration for the specified resources with the default options.</div> </td> @@ -172,73 +172,73 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <tr class="rowColor"> <td class="colFirst"><code>abstract void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#close(long,%20java.util.concurrent.TimeUnit)">close</a></strong>(long duration, - <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> unit)</code> + java.util.concurrent.TimeUnit unit)</code> <div class="block">Close the AdminClient and release all associated resources.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code>static <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#create(java.util.Map)">create</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>> conf)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#create(java.util.Map)">create</a></strong>(java.util.Map<java.lang.String,java.lang.Object> conf)</code> <div class="block">Create a new AdminClient with the given configuration.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>static <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#create(java.util.Properties)">create</a></strong>(<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> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#create(java.util.Properties)">create</a></strong>(java.util.Properties props)</code> <div class="block">Create a new AdminClient with the given configuration.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createAcls(java.util.Collection)">createAcls</a></strong>(<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/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createAcls(java.util.Collection)">createAcls</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls)</code> <div class="block">Similar to #<code>AdminClient#createAcls(Collection<AclBinding>, CreateAclsOptions)</code>, but uses the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createAcls(java.util.Collection,%20org.apache.kafka.clients.admin.CreateAclsOptions)">createAcls</a></strong>(<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/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createAcls(java.util.Collection,%20org.apache.kafka.clients.admin.CreateAclsOptions)">createAcls</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls, <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsOptions.html" title="class in org.apache.kafka.clients.admin">CreateAclsOptions</a> options)</code> <div class="block">Creates access control lists (ACLs) which are bound to specific resources.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createTopics(java.util.Collection)">createTopics</a></strong>(<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/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createTopics(java.util.Collection)">createTopics</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics)</code> <div class="block">Create a batch of new topics with the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createTopics(java.util.Collection,%20org.apache.kafka.clients.admin.CreateTopicsOptions)">createTopics</a></strong>(<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/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#createTopics(java.util.Collection,%20org.apache.kafka.clients.admin.CreateTopicsOptions)">createTopics</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics, <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsOptions.html" title="class in org.apache.kafka.clients.admin">CreateTopicsOptions</a> options)</code> <div class="block">Create a batch of new topics.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteAcls(java.util.Collection)">deleteAcls</a></strong>(<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/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteAcls(java.util.Collection)">deleteAcls</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters)</code> <div class="block">Similar to #<code>AdminClient#deleteAcls(Collection<AclBinding>, DeleteAclsOptions)</code>, but uses the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteAcls(java.util.Collection,%20org.apache.kafka.clients.admin.DeleteAclsOptions)">deleteAcls</a></strong>(<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/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteAcls(java.util.Collection,%20org.apache.kafka.clients.admin.DeleteAclsOptions)">deleteAcls</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters, <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsOptions.html" title="class in org.apache.kafka.clients.admin">DeleteAclsOptions</a> options)</code> <div class="block">Deletes access control lists (ACLs) according to the supplied filters.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteTopics(java.util.Collection)">deleteTopics</a></strong>(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topics)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteTopics(java.util.Collection)">deleteTopics</a></strong>(java.util.Collection<java.lang.String> topics)</code> <div class="block">Similar to #<code>AdminClient#deleteTopics(Collection<String>, DeleteTopicsOptions)</code>, but uses the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteTopics(java.util.Collection,%20org.apache.kafka.clients.admin.DeleteTopicsOptions)">deleteTopics</a></strong>(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topics, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#deleteTopics(java.util.Collection,%20org.apache.kafka.clients.admin.DeleteTopicsOptions)">deleteTopics</a></strong>(java.util.Collection<java.lang.String> topics, <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsOptions.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsOptions</a> options)</code> <div class="block">Delete a batch of topics.</div> </td> @@ -271,26 +271,26 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeConfigs(java.util.Collection)">describeConfigs</a></strong>(<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/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeConfigs(java.util.Collection)">describeConfigs</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources)</code> <div class="block">Get the configuration for the specified resources with the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeConfigs(java.util.Collection,%20org.apache.kafka.clients.admin.DescribeConfigsOptions)">describeConfigs</a></strong>(<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/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeConfigs(java.util.Collection,%20org.apache.kafka.clients.admin.DescribeConfigsOptions)">describeConfigs</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources, <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsOptions.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsOptions</a> options)</code> <div class="block">Get the configuration for the specified resources.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeTopics(java.util.Collection)">describeTopics</a></strong>(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topicNames)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeTopics(java.util.Collection)">describeTopics</a></strong>(java.util.Collection<java.lang.String> topicNames)</code> <div class="block">Describe some topics in the cluster, with the default options.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeTopics(java.util.Collection,%20org.apache.kafka.clients.admin.DescribeTopicsOptions)">describeTopics</a></strong>(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topicNames, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeTopics(java.util.Collection,%20org.apache.kafka.clients.admin.DescribeTopicsOptions)">describeTopics</a></strong>(java.util.Collection<java.lang.String> topicNames, <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsOptions.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsOptions</a> options)</code> <div class="block">Describe some topics in the cluster.</div> </td> @@ -312,8 +312,8 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <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#toString()" title="class or interface in java.lang">toString</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, toString, wait, wait, wait</code></li> </ul> </li> </ul> @@ -352,7 +352,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>create</h4> -<pre>public static <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a> create(<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> +<pre>public static <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a> create(java.util.Properties props)</pre> <div class="block">Create a new AdminClient with the given configuration.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>props</code> - The configuration.</dd> <dt><span class="strong">Returns:</span></dt><dd>The new KafkaAdminClient.</dd></dl> @@ -364,7 +364,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>create</h4> -<pre>public static <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a> create(<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>> conf)</pre> +<pre>public static <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a> create(java.util.Map<java.lang.String,java.lang.Object> conf)</pre> <div class="block">Create a new AdminClient with the given configuration.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>conf</code> - The configuration.</dd> <dt><span class="strong">Returns:</span></dt><dd>The new KafkaAdminClient.</dd></dl> @@ -382,7 +382,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose See <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#close(long,%20java.util.concurrent.TimeUnit)"><code>close(long, TimeUnit)</code></a></div> <dl> <dt><strong>Specified by:</strong></dt> -<dd><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> in interface <code><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></code></dd> +<dd><code>close</code> in interface <code>java.lang.AutoCloseable</code></dd> </dl> </li> </ul> @@ -393,7 +393,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <li class="blockList"> <h4>close</h4> <pre>public abstract void close(long duration, - <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> unit)</pre> + java.util.concurrent.TimeUnit unit)</pre> <div class="block">Close the AdminClient and release all associated resources. The close operation has a grace period during which current operations will be allowed to @@ -409,7 +409,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>createTopics</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a> createTopics(<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/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a> createTopics(java.util.Collection<<a href="../../../../../org/apache/kafka/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics)</pre> <div class="block">Create a batch of new topics with the default options. This operation is supported by brokers with version 0.10.1.0 or higher.</div> @@ -423,7 +423,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>createTopics</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a> createTopics(<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/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a> createTopics(java.util.Collection<<a href="../../../../../org/apache/kafka/clients/admin/NewTopic.html" title="class in org.apache.kafka.clients.admin">NewTopic</a>> newTopics, <a href="../../../../../org/apache/kafka/clients/admin/CreateTopicsOptions.html" title="class in org.apache.kafka.clients.admin">CreateTopicsOptions</a> options)</pre> <div class="block">Create a batch of new topics. @@ -444,7 +444,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>deleteTopics</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a> deleteTopics(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topics)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a> deleteTopics(java.util.Collection<java.lang.String> topics)</pre> <div class="block">Similar to #<code>AdminClient#deleteTopics(Collection<String>, DeleteTopicsOptions)</code>, but uses the default options. @@ -459,7 +459,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>deleteTopics</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a> deleteTopics(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topics, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a> deleteTopics(java.util.Collection<java.lang.String> topics, <a href="../../../../../org/apache/kafka/clients/admin/DeleteTopicsOptions.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsOptions</a> options)</pre> <div class="block">Delete a batch of topics. @@ -506,7 +506,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>describeTopics</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a> describeTopics(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topicNames)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a> describeTopics(java.util.Collection<java.lang.String> topicNames)</pre> <div class="block">Describe some topics in the cluster, with the default options. See <code>AdminClient#describeTopics(Collection<String>, DescribeTopicsOptions)</code></div> @@ -520,7 +520,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>describeTopics</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a> describeTopics(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> topicNames, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a> describeTopics(java.util.Collection<java.lang.String> topicNames, <a href="../../../../../org/apache/kafka/clients/admin/DescribeTopicsOptions.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsOptions</a> options)</pre> <div class="block">Describe some topics in the cluster.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>topicNames</code> - The names of the topics to describe.</dd><dd><code>options</code> - The options to use when describing the topic.</dd> @@ -589,7 +589,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>createAcls</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a> createAcls(<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/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a> createAcls(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls)</pre> <div class="block">Similar to #<code>AdminClient#createAcls(Collection<AclBinding>, CreateAclsOptions)</code>, but uses the default options. @@ -604,7 +604,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>createAcls</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a> createAcls(<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/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a> createAcls(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a>> acls, <a href="../../../../../org/apache/kafka/clients/admin/CreateAclsOptions.html" title="class in org.apache.kafka.clients.admin">CreateAclsOptions</a> options)</pre> <div class="block">Creates access control lists (ACLs) which are bound to specific resources. @@ -622,7 +622,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>deleteAcls</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a> deleteAcls(<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/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a> deleteAcls(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters)</pre> <div class="block">Similar to #<code>AdminClient#deleteAcls(Collection<AclBinding>, DeleteAclsOptions)</code>, but uses the default options. @@ -637,7 +637,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>deleteAcls</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a> deleteAcls(<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/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a> deleteAcls(java.util.Collection<<a href="../../../../../org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a>> filters, <a href="../../../../../org/apache/kafka/clients/admin/DeleteAclsOptions.html" title="class in org.apache.kafka.clients.admin">DeleteAclsOptions</a> options)</pre> <div class="block">Deletes access control lists (ACLs) according to the supplied filters. @@ -652,7 +652,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>describeConfigs</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a> describeConfigs(<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/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a> describeConfigs(java.util.Collection<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources)</pre> <div class="block">Get the configuration for the specified resources with the default options. See <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#describeConfigs(java.util.Collection,%20org.apache.kafka.clients.admin.DescribeConfigsOptions)"><code>describeConfigs(Collection, DescribeConfigsOptions)</code></a> for more details. @@ -668,7 +668,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>describeConfigs</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a> describeConfigs(<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/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a> describeConfigs(java.util.Collection<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>> resources, <a href="../../../../../org/apache/kafka/clients/admin/DescribeConfigsOptions.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsOptions</a> options)</pre> <div class="block">Get the configuration for the specified resources. @@ -691,7 +691,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockList"> <li class="blockList"> <h4>alterConfigs</h4> -<pre>public <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a> alterConfigs(<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/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs)</pre> +<pre>public <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a> alterConfigs(java.util.Map<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs)</pre> <div class="block">Update the configuration for the specified resources with the default options. See <a href="../../../../../org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map,%20org.apache.kafka.clients.admin.AlterConfigsOptions)"><code>alterConfigs(Map, AlterConfigsOptions)</code></a> for more details. @@ -708,7 +708,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoClose <ul class="blockListLast"> <li class="blockList"> <h4>alterConfigs</h4> -<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a> alterConfigs(<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/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs, +<pre>public abstract <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a> alterConfigs(java.util.Map<<a href="../../../../../org/apache/kafka/common/config/ConfigResource.html" title="class in org.apache.kafka.common.config">ConfigResource</a>,<a href="../../../../../org/apache/kafka/clients/admin/Config.html" title="class in org.apache.kafka.clients.admin">Config</a>> configs, <a href="../../../../../org/apache/kafka/clients/admin/AlterConfigsOptions.html" title="class in org.apache.kafka.clients.admin">AlterConfigsOptions</a> options)</pre> <div class="block">Update the configuration for the specified resources with the default options.
