kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [15/17] kafka-site git commit: update 0.9.0 docs
Date Fri, 13 Nov 2015 17:40:37 GMT
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/e047c4b2/090/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/090/javadoc/index-all.html b/090/javadoc/index-all.html
index deea6a6..77d62e3 100644
--- a/090/javadoc/index-all.html
+++ b/090/javadoc/index-all.html
@@ -2,15 +2,15 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (version 1.7.0_51) on Fri Feb 13 15:47:45 PST 2015 -->
-<title>Index (clients 0.8.3-SNAPSHOT API)</title>
-<meta name="date" content="2015-02-13">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 13 08:33:06 PST 2015 -->
+<title>Index (clients 0.9.0.0 API)</title>
+<meta name="date" content="2015-11-13">
 <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 (clients 0.8.3-SNAPSHOT API)";
+        parent.document.title="Index (clients 0.9.0.0 API)";
     }
 //-->
 </script>
@@ -61,7 +61,7 @@
 <!--   -->
 </a></div>
 <!-- ========= END OF TOP NAVBAR ========= -->
-<div class="contentContainer"><a href="#_A_">A</a>&nbsp;<a href="#_B_">B</a>&nbsp;<a href="#_C_">C</a>&nbsp;<a href="#_D_">D</a>&nbsp;<a href="#_E_">E</a>&nbsp;<a href="#_F_">F</a>&nbsp;<a href="#_G_">G</a>&nbsp;<a href="#_H_">H</a>&nbsp;<a href="#_I_">I</a>&nbsp;<a href="#_K_">K</a>&nbsp;<a href="#_L_">L</a>&nbsp;<a href="#_M_">M</a>&nbsp;<a href="#_N_">N</a>&nbsp;<a href="#_O_">O</a>&nbsp;<a href="#_P_">P</a>&nbsp;<a href="#_R_">R</a>&nbsp;<a href="#_S_">S</a>&nbsp;<a href="#_T_">T</a>&nbsp;<a href="#_U_">U</a>&nbsp;<a href="#_V_">V</a>&nbsp;<a name="_A_">
+<div class="contentContainer"><a href="#_A_">A</a>&nbsp;<a href="#_B_">B</a>&nbsp;<a href="#_C_">C</a>&nbsp;<a href="#_D_">D</a>&nbsp;<a href="#_E_">E</a>&nbsp;<a href="#_F_">F</a>&nbsp;<a href="#_G_">G</a>&nbsp;<a href="#_H_">H</a>&nbsp;<a href="#_I_">I</a>&nbsp;<a href="#_K_">K</a>&nbsp;<a href="#_L_">L</a>&nbsp;<a href="#_M_">M</a>&nbsp;<a href="#_N_">N</a>&nbsp;<a href="#_O_">O</a>&nbsp;<a href="#_P_">P</a>&nbsp;<a href="#_R_">R</a>&nbsp;<a href="#_S_">S</a>&nbsp;<a href="#_T_">T</a>&nbsp;<a href="#_U_">U</a>&nbsp;<a href="#_V_">V</a>&nbsp;<a href="#_W_">W</a>&nbsp;<a name="_A_">
 <!--   -->
 </a>
 <h2 class="title">A</h2>
@@ -70,14 +70,24 @@
 <dd>
 <div class="block"><code>acks</code></div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig(java.util.Map,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">addDeserializerToConfig(Map&lt;String, Object&gt;, Deserializer&lt;?&gt;, Deserializer&lt;?&gt;)</a></span> - Static method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">addDeserializerToConfig(Properties, Deserializer&lt;?&gt;, Deserializer&lt;?&gt;)</a></span> - Static method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#addRecord(org.apache.kafka.clients.consumer.ConsumerRecord)">addRecord(ConsumerRecord&lt;K, V&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig(java.util.Map,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Map&lt;String, Object&gt;, Serializer&lt;?&gt;, Serializer&lt;?&gt;)</a></span> - Static method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Properties, Serializer&lt;?&gt;, Serializer&lt;?&gt;)</a></span> - Static method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html#allPartitionsSorted(java.util.Map,%20java.util.Map)">allPartitionsSorted(Map&lt;String, Integer&gt;, Map&lt;String, List&lt;String&gt;&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt>
+<dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors"><span class="strong">ApiException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
 <dd>
 <div class="block">Any API exception that is part of the public protocol and should be a subclass of this class and be part of this
  package.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.String, java.lang.Throwable)">ApiException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.String,%20java.lang.Throwable)">ApiException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.String)">ApiException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt>
 <dd>&nbsp;</dd>
@@ -85,6 +95,30 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException()">ApiException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#assign(java.util.List)">assign(List&lt;TopicPartition&gt;)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.List)">assign(List&lt;TopicPartition&gt;)</a></span> - Method in 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">Manually assign a list of partition to this consumer.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#assign(java.util.List)">assign(List&lt;TopicPartition&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RangeAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map&lt;String, Integer&gt;, Map&lt;String, List&lt;String&gt;&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RangeAssignor.html" title="class in org.apache.kafka.clients.consumer">RangeAssignor</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map&lt;String, Integer&gt;, Map&lt;String, List&lt;String&gt;&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#assignment()">assignment()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#assignment()">assignment()</a></span> - Method in 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">Get the set of partitions currently assigned to this consumer.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#assignment()">assignment()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">AuthorizationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthorizationException.html#AuthorizationException(java.lang.String)">AuthorizationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_COMMIT_INTERVAL_MS_CONFIG">AUTO_COMMIT_INTERVAL_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
 <dd>
 <div class="block"><code>auto.commit.interval.ms</code></div>
@@ -93,6 +127,10 @@
 <dd>
 <div class="block"><code>auto.offset.reset</code></div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#availablePartitionsForTopic(java.lang.String)">availablePartitionsForTopic(String)</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>
+<div class="block">Get the list of available partitions for this topic</div>
+</dd>
 </dl>
 <a name="_B_">
 <!--   -->
@@ -105,7 +143,9 @@
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#BLOCK_ON_BUFFER_FULL_CONFIG">BLOCK_ON_BUFFER_FULL_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
 <dd>
-<div class="block"><code>block.on.buffer.full</code></div>
+<div class="block"><span class="strong">Deprecated.</span>
+<div class="block"><i>This config will be removed in a future release. Also, the <a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_FETCH_TIMEOUT_CONFIG"><code>ProducerConfig.METADATA_FETCH_TIMEOUT_CONFIG</code></a> is no longer honored when this property is set to true.</i></div>
+</div>
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)">bootstrap(List&lt;InetSocketAddress&gt;)</a></span> - Static 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>
@@ -119,6 +159,12 @@
 <dd>
 <div class="block"><code>bootstrap.servers</code></div>
 </dd>
+<dt><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors"><span class="strong">BrokerNotAvailableException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html#BrokerNotAvailableException(java.lang.String)">BrokerNotAvailableException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors">BrokerNotAvailableException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html#BrokerNotAvailableException(java.lang.String,%20java.lang.Throwable)">BrokerNotAvailableException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors">BrokerNotAvailableException</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#BUFFER_MEMORY_CONFIG">BUFFER_MEMORY_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
 <dd>
 <div class="block"><code>buffer.memory</code></div>
@@ -167,70 +213,123 @@
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#close()">close()</a></span> - Method in 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>&nbsp;</dd>
+<dd>
+<div class="block">Close the consumer, waiting indefinitely for any needed cleanup.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#close()">close()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#close()">close()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer">KafkaProducer</a></dt>
 <dd>
 <div class="block">Close this producer.</div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#close(long,%20java.util.concurrent.TimeUnit)">close(long, TimeUnit)</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer">KafkaProducer</a></dt>
+<dd>
+<div class="block">This method waits up to <code>timeout</code> for the producer to complete the sending of all incomplete requests.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#close()">close()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#close(long,%20java.util.concurrent.TimeUnit)">close(long, TimeUnit)</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Partitioner.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Partitioner.html" title="interface in org.apache.kafka.clients.producer">Partitioner</a></dt>
+<dd>
+<div class="block">This is called when partitioner is closed.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a></dt>
 <dd>
 <div class="block">Close this producer</div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#close(long,%20java.util.concurrent.TimeUnit)">close(long, TimeUnit)</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a></dt>
+<dd>
+<div class="block">Tries to close the producer cleanly within the specified timeout.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteArrayDeserializer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html" title="class in org.apache.kafka.common.serialization">ByteArraySerializer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#close()">close()</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a></dt>
-<dd>
-<div class="block">Close this deserializer</div>
-</dd>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization">IntegerSerializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization">LongDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongSerializer.html" title="class in org.apache.kafka.common.serialization">LongSerializer</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serializer.html#close()">close()</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization">Serializer</a></dt>
 <dd>
-<div class="block">Close this serializer</div>
+<div class="block">Close this serializer.</div>
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization">StringDeserializer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization">StringSerializer</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#closed()">closed()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common"><span class="strong">Cluster</span></a> - Class in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
 <dd>
 <div class="block">A representation of a subset of the nodes, topics, and partitions in the Kafka cluster.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#Cluster(java.util.Collection, java.util.Collection)">Cluster(Collection&lt;Node&gt;, Collection&lt;PartitionInfo&gt;)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#Cluster(java.util.Collection,%20java.util.Collection,%20java.util.Set)">Cluster(Collection&lt;Node&gt;, Collection&lt;PartitionInfo&gt;, Set&lt;String&gt;)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt>
 <dd>
 <div class="block">Create a new cluster with the given nodes and partitions</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commit(org.apache.kafka.clients.consumer.CommitType)">commit(CommitType)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync()">commitAsync()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(Map&lt;TopicPartition, OffsetAndMetadata&gt;, OffsetCommitCallback)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync()">commitAsync()</a></span> - Method in 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">Commit offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for all the subscribed list of topics and partition.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in 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">Commit offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for the subscribed list of topics and partitions.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(Map&lt;TopicPartition, OffsetAndMetadata&gt;, OffsetCommitCallback)</a></span> - Method in 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">Commit the specified offsets for the specified list of topics and partitions to Kafka.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(Map&lt;TopicPartition, OffsetAndMetadata&gt;, OffsetCommitCallback)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync()">commitAsync()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/clients/consumer/CommitFailedException.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">CommitFailedException</span></a> - Exception in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd>
+<div class="block">This exception is raised when an offset commit with <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync()"><code>KafkaConsumer.commitSync()</code></a> fails
+ with an unrecoverable error.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/CommitFailedException.html#CommitFailedException(java.lang.String)">CommitFailedException(String)</a></span> - Constructor for exception org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/CommitFailedException.html" title="class in org.apache.kafka.clients.consumer">CommitFailedException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitSync()">commitSync()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commit(java.util.Map, org.apache.kafka.clients.consumer.CommitType)">commit(Map&lt;TopicPartition, Long&gt;, CommitType)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitSync(java.util.Map)">commitSync(Map&lt;TopicPartition, OffsetAndMetadata&gt;)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commit(java.util.Map, org.apache.kafka.clients.consumer.CommitType)">commit(Map&lt;TopicPartition, Long&gt;, CommitType)</a></span> - Method in 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>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync()">commitSync()</a></span> - Method in 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">Commits the specified offsets for the specified list of topics and partitions to Kafka.</div>
+<div class="block">Commit offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for all the subscribed list of topics and partitions.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commit(org.apache.kafka.clients.consumer.CommitType)">commit(CommitType)</a></span> - Method in 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>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)">commitSync(Map&lt;TopicPartition, OffsetAndMetadata&gt;)</a></span> - Method in 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">Commits offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for the subscribed list of topics and partitions.</div>
+<div class="block">Commit the specified offsets for the specified list of topics and partitions.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commit(java.util.Map, org.apache.kafka.clients.consumer.CommitType)">commit(Map&lt;TopicPartition, Long&gt;, CommitType)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitSync(java.util.Map)">commitSync(Map&lt;TopicPartition, OffsetAndMetadata&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commit(org.apache.kafka.clients.consumer.CommitType)">commit(CommitType)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitSync()">commitSync()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#committed(org.apache.kafka.common.TopicPartition)">committed(TopicPartition)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#committed(org.apache.kafka.common.TopicPartition)">committed(TopicPartition)</a></span> - Method in 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">Fetches the last committed offset for the given partition (whether the commit happened by this process or
+<div class="block">Get the last committed offset for the given partition (whether the commit happened by this process or
  another).</div>
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#committed(org.apache.kafka.common.TopicPartition)">committed(TopicPartition)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
-<dt><a href="./org/apache/kafka/clients/consumer/CommitType.html" title="enum in org.apache.kafka.clients.consumer"><span class="strong">CommitType</span></a> - Enum in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
-<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#completeNext()">completeNext()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt>
 <dd>
 <div class="block">Complete the earliest uncompleted call successfully.</div>
@@ -247,33 +346,45 @@
 <dd>
 <div class="block">Configure this class with the given key-value pairs</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#configure(java.util.Map, boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteArrayDeserializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteArrayDeserializer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html#configure(java.util.Map, boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html" title="class in org.apache.kafka.common.serialization">ByteArraySerializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html" title="class in org.apache.kafka.common.serialization">ByteArraySerializer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#configure(java.util.Map, boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a></dt>
 <dd>
 <div class="block">Configure this class.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serializer.html#configure(java.util.Map, boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization">Serializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerSerializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization">IntegerSerializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization">LongDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongSerializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongSerializer.html" title="class in org.apache.kafka.common.serialization">LongSerializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization">Serializer</a></dt>
 <dd>
 <div class="block">Configure this class.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringDeserializer.html#configure(java.util.Map, boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization">StringDeserializer</a></dt>
-<dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringSerializer.html#configure(java.util.Map, boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization">StringSerializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization">StringDeserializer</a></dt>
 <dd>&nbsp;</dd>
-<dt><a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">Consumer</span></a>&lt;<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="type parameter in Consumer">K</a>,<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="type parameter in Consumer">V</a>&gt; - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringSerializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization">StringSerializer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#CONSUMER_REBALANCE_CALLBACK_CLASS_CONFIG">CONSUMER_REBALANCE_CALLBACK_CLASS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG">CONNECTIONS_MAX_IDLE_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
 <dd>
-<div class="block"><code>rebalance.callback.class</code></div>
+<div class="block"><code>connections.max.idle.ms</code></div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG">CONNECTIONS_MAX_IDLE_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
+<dd>
+<div class="block"><code>connections.max.idle.ms</code></div>
+</dd>
+<dt><a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">Consumer</span></a>&lt;<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="type parameter in Consumer">K</a>,<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="type parameter in Consumer">V</a>&gt; - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">ConsumerConfig</span></a> - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
 <dd>
 <div class="block">The consumer configuration keys</div>
 </dd>
-<dt><a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceCallback.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRebalanceCallback</span></a> - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dt><a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRebalanceListener</span></a> - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
 <dd>
 <div class="block">A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the
  consumer changes.</div>
@@ -282,9 +393,9 @@
 <dd>
 <div class="block">A key/value pair to be received from Kafka.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html#ConsumerRecord(java.lang.String, int, long, K, V)">ConsumerRecord(String, int, long, K, V)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecord</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html#ConsumerRecord(java.lang.String,%20int,%20long,%20K,%20V)">ConsumerRecord(String, int, long, K, V)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecord</a></dt>
 <dd>
-<div class="block">Create a record with no key</div>
+<div class="block">Creates a record to be received from a specified topic and partition</div>
 </dd>
 <dt><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRecords</span></a>&lt;<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="type parameter in ConsumerRecords">K</a>,<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="type parameter in ConsumerRecords">V</a>&gt; - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
 <dd>
@@ -293,9 +404,15 @@
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#ConsumerRecords(java.util.Map)">ConsumerRecords(Map&lt;TopicPartition, List&lt;ConsumerRecord&lt;K, V&gt;&gt;&gt;)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
 <dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors"><span class="strong">ControllerMovedException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ControllerMovedException.html#ControllerMovedException(java.lang.String)">ControllerMovedException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ControllerMovedException.html#ControllerMovedException(java.lang.String,%20java.lang.Throwable)">ControllerMovedException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></dt>
+<dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors"><span class="strong">CorruptRecordException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
 <dd>
-<div class="block">This exception indicates a record has failed it's internal CRC check, this generally indicates network or disk
+<div class="block">This exception indicates a record has failed its internal CRC check, this generally indicates network or disk
  corruption.</div>
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException()">CorruptRecordException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></dt>
@@ -304,7 +421,7 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.Throwable)">CorruptRecordException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.String, java.lang.Throwable)">CorruptRecordException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.String,%20java.lang.Throwable)">CorruptRecordException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#count()">count()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
 <dd>
@@ -318,20 +435,40 @@
 <dl>
 <dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#description()">description()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#deserialize(java.lang.String, byte[])">deserialize(String, byte[])</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteArrayDeserializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#deserialize(java.lang.String,%20byte[])">deserialize(String, byte[])</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteArrayDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#deserialize(java.lang.String,%20byte[])">deserialize(String, byte[])</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#deserialize(java.lang.String, byte[])">deserialize(String, byte[])</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization">Deserializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html#deserialize(java.lang.String,%20byte[])">deserialize(String, byte[])</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringDeserializer.html#deserialize(java.lang.String, byte[])">deserialize(String, byte[])</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization">StringDeserializer</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongDeserializer.html#deserialize(java.lang.String,%20byte[])">deserialize(String, byte[])</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization">LongDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringDeserializer.html#deserialize(java.lang.String,%20byte[])">deserialize(String, byte[])</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization">StringDeserializer</a></dt>
 <dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization"><span class="strong">Deserializer</span></a>&lt;<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="type parameter in Deserializer">T</a>&gt; - Interface in <a href="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</a></dt>
 <dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors"><span class="strong">DisconnectException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>
+<div class="block">Server disconnected before a request could be completed.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/DisconnectException.html#DisconnectException()">DisconnectException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/DisconnectException.html#DisconnectException(java.lang.String,%20java.lang.Throwable)">DisconnectException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/DisconnectException.html#DisconnectException(java.lang.String)">DisconnectException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/DisconnectException.html#DisconnectException(java.lang.Throwable)">DisconnectException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></dt>
+<dd>&nbsp;</dd>
 </dl>
 <a name="_E_">
 <!--   -->
 </a>
 <h2 class="title">E</h2>
 <dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#EMPTY">EMPTY</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#empty()">empty()</a></span> - Static method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#empty()">empty()</a></span> - Static 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>
 <div class="block">Create an empty cluster instance with no nodes and no topic-partitions.</div>
@@ -340,6 +477,10 @@
 <dd>
 <div class="block"><code>enable.auto.commit</code></div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/OffsetAndMetadata.html#equals(java.lang.Object)">equals(Object)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerRecord.html#equals(java.lang.Object)">equals(Object)</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#equals(java.lang.Object)">equals(Object)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/Node.html#equals(java.lang.Object)">equals(Object)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</a></dt>
@@ -368,6 +509,17 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/SerializationException.html#fillInStackTrace()">fillInStackTrace()</a></span> - Method in exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/SerializationException.html" title="class in org.apache.kafka.common.errors">SerializationException</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#flush()">flush()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer">KafkaProducer</a></dt>
+<dd>
+<div class="block">Invoking this method makes all buffered records immediately available to send (even if <code>linger.ms</code> is
+ greater than 0) and blocks on the completion of the requests associated with these records.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#flush()">flush()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#flush()">flush()</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a></dt>
+<dd>
+<div class="block">Flush any accumulated records from the producer.</div>
+</dd>
 </dl>
 <a name="_G_">
 <!--   -->
@@ -380,18 +532,58 @@
 <dd>
 <div class="block"><code>group.id</code></div>
 </dd>
+<dt><a href="./org/apache/kafka/common/errors/GroupAuthorizationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">GroupAuthorizationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupAuthorizationException.html#GroupAuthorizationException(java.lang.String)">GroupAuthorizationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupAuthorizationException.html" title="class in org.apache.kafka.common.errors">GroupAuthorizationException</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors"><span class="strong">GroupCoordinatorNotAvailableException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>
+<div class="block">The broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has
+ not yet been created.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html#GroupCoordinatorNotAvailableException()">GroupCoordinatorNotAvailableException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors">GroupCoordinatorNotAvailableException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html#GroupCoordinatorNotAvailableException(java.lang.String)">GroupCoordinatorNotAvailableException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors">GroupCoordinatorNotAvailableException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html#GroupCoordinatorNotAvailableException(java.lang.String,%20java.lang.Throwable)">GroupCoordinatorNotAvailableException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors">GroupCoordinatorNotAvailableException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html#GroupCoordinatorNotAvailableException(java.lang.Throwable)">GroupCoordinatorNotAvailableException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors">GroupCoordinatorNotAvailableException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupAuthorizationException.html#groupId()">groupId()</a></span> - Method in exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupAuthorizationException.html" title="class in org.apache.kafka.common.errors">GroupAuthorizationException</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors"><span class="strong">GroupLoadInProgressException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>
+<div class="block">The broker returns this error code for any coordiantor request if it is still loading the metadata (after a leader change
+ for that offsets topic partition) for this group.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html#GroupLoadInProgressException()">GroupLoadInProgressException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors">GroupLoadInProgressException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html#GroupLoadInProgressException(java.lang.String)">GroupLoadInProgressException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors">GroupLoadInProgressException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html#GroupLoadInProgressException(java.lang.String,%20java.lang.Throwable)">GroupLoadInProgressException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors">GroupLoadInProgressException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html#GroupLoadInProgressException(java.lang.Throwable)">GroupLoadInProgressException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors">GroupLoadInProgressException</a></dt>
+<dd>&nbsp;</dd>
 </dl>
 <a name="_H_">
 <!--   -->
 </a>
 <h2 class="title">H</h2>
 <dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/OffsetAndMetadata.html#hashCode()">hashCode()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerRecord.html#hashCode()">hashCode()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#hashCode()">hashCode()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/Node.html#hashCode()">hashCode()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/TopicPartition.html#hashCode()">hashCode()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#HEARTBEAT_INTERVAL_MS_CONFIG">HEARTBEAT_INTERVAL_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
+<dd>
+<div class="block"><code>heartbeat.interval.ms</code></div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#history()">history()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt>
 <dd>
 <div class="block">Get the list of sent records since the last call to <a href="./org/apache/kafka/clients/producer/MockProducer.html#clear()"><code>MockProducer.clear()</code></a></div>
@@ -410,11 +602,43 @@
 <dd>
 <div class="block">The node id of this node</div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Node.html#idString()">idString()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</a></dt>
+<dd>
+<div class="block">String representation of the node id.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">IllegalGenerationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/IllegalGenerationException.html#IllegalGenerationException()">IllegalGenerationException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors">IllegalGenerationException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/IllegalGenerationException.html#IllegalGenerationException(java.lang.String,%20java.lang.Throwable)">IllegalGenerationException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors">IllegalGenerationException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/IllegalGenerationException.html#IllegalGenerationException(java.lang.String)">IllegalGenerationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors">IllegalGenerationException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/IllegalGenerationException.html#IllegalGenerationException(java.lang.Throwable)">IllegalGenerationException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors">IllegalGenerationException</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/PartitionInfo.html#inSyncReplicas()">inSyncReplicas()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a></dt>
 <dd>
 <div class="block">The subset of the replicas that are in sync, that is caught-up to the leader and ready to take over as leader if
  the leader should fail</div>
 </dd>
+<dt><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">IntegerDeserializer</span></a> - Class in <a href="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html#IntegerDeserializer()">IntegerDeserializer()</a></span> - Constructor for class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">IntegerSerializer</span></a> - Class in <a href="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerSerializer.html#IntegerSerializer()">IntegerSerializer()</a></span> - Constructor for class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization">IntegerSerializer</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/InterruptException.html" title="class in org.apache.kafka.common.errors"><span class="strong">InterruptException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>
+<div class="block">An unchecked wrapper for InterruptedException</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InterruptException.html#InterruptException(java.lang.InterruptedException)">InterruptException(InterruptedException)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InterruptException.html" title="class in org.apache.kafka.common.errors">InterruptException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InterruptException.html#InterruptException(java.lang.String,%20java.lang.InterruptedException)">InterruptException(String, InterruptedException)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InterruptException.html" title="class in org.apache.kafka.common.errors">InterruptException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InterruptException.html#InterruptException(java.lang.String)">InterruptException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InterruptException.html" title="class in org.apache.kafka.common.errors">InterruptException</a></dt>
+<dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/errors/InvalidMetadataException.html" title="class in org.apache.kafka.common.errors"><span class="strong">InvalidMetadataException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
 <dd>
 <div class="block">An exception that may indicate the client's metadata is out of date</div>
@@ -423,22 +647,35 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.String)">InvalidMetadataException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidMetadataException.html" title="class in org.apache.kafka.common.errors">InvalidMetadataException</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.String, java.lang.Throwable)">InvalidMetadataException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidMetadataException.html" title="class in org.apache.kafka.common.errors">InvalidMetadataException</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.String,%20java.lang.Throwable)">InvalidMetadataException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidMetadataException.html" title="class in org.apache.kafka.common.errors">InvalidMetadataException</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.Throwable)">InvalidMetadataException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidMetadataException.html" title="class in org.apache.kafka.common.errors">InvalidMetadataException</a></dt>
 <dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/clients/consumer/InvalidOffsetException.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">InvalidOffsetException</span></a> - Exception in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd>
+<div class="block">Thrown when the offset for a set of partitions is invalid (either undefined or out of range),
+ and no reset policy has been configured.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/InvalidOffsetException.html#InvalidOffsetException(java.lang.String)">InvalidOffsetException(String)</a></span> - Constructor for exception org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/InvalidOffsetException.html" title="class in org.apache.kafka.clients.consumer">InvalidOffsetException</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/common/errors/InvalidRequiredAcksException.html" title="class in org.apache.kafka.common.errors"><span class="strong">InvalidRequiredAcksException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidRequiredAcksException.html#InvalidRequiredAcksException(java.lang.String)">InvalidRequiredAcksException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidRequiredAcksException.html" title="class in org.apache.kafka.common.errors">InvalidRequiredAcksException</a></dt>
+<dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors"><span class="strong">InvalidTopicException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
 <dd>
 <div class="block">The client has attempted to perform an operation on an invalid topic.</div>
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException()">InvalidTopicException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors">InvalidTopicException</a></dt>
 <dd>&nbsp;</dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.String, java.lang.Throwable)">InvalidTopicException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors">InvalidTopicException</a></dt>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.String,%20java.lang.Throwable)">InvalidTopicException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors">InvalidTopicException</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.String)">InvalidTopicException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors">InvalidTopicException</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.Throwable)">InvalidTopicException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors">InvalidTopicException</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#isEmpty()">isEmpty()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#iterator()">iterator()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
 <dd>&nbsp;</dd>
 </dl>
@@ -455,25 +692,25 @@
 <dd>
 <div class="block">A consumer is instantiated by providing a set of key-value pairs as configuration.</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map, org.apache.kafka.clients.consumer.ConsumerRebalanceCallback, org.apache.kafka.common.serialization.Deserializer, org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer(Map&lt;String, Object&gt;, ConsumerRebalanceCallback, Deserializer&lt;K&gt;, Deserializer&lt;V&gt;)</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>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer(Map&lt;String, Object&gt;, Deserializer&lt;K&gt;, Deserializer&lt;V&gt;)</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 set of key-value pairs as configuration, a
- <a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceCallback.html" title="interface in org.apache.kafka.clients.consumer"><code>ConsumerRebalanceCallback</code></a> implementation, 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>
+ <a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer"><code>ConsumerRebalanceListener</code></a> implementation, 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><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 <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, org.apache.kafka.clients.consumer.ConsumerRebalanceCallback, org.apache.kafka.common.serialization.Deserializer, org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer(Properties, ConsumerRebalanceCallback, Deserializer&lt;K&gt;, Deserializer&lt;V&gt;)</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>
+<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&lt;K&gt;, Deserializer&lt;V&gt;)</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 <code>Properties</code> object as configuration and a
- <a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceCallback.html" title="interface in org.apache.kafka.clients.consumer"><code>ConsumerRebalanceCallback</code></a> implementation, 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>
+ <a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer"><code>ConsumerRebalanceListener</code></a> implementation, 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>
 <dd>
 <div class="block">The base class of all other Kafka exceptions</div>
 </dd>
-<dt><span class="strong"><a href="./org/apache/kafka/common/KafkaException.html#KafkaException(java.lang.String, java.lang.Throwable)">KafkaException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.<a hre

<TRUNCATED>

Mime
View raw message