You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2015/10/02 21:19:25 UTC
[27/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload
of Kafka documentation to git repository with intent to replace SVN
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ba6c994c/090/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/090/javadoc/index-all.html b/090/javadoc/index-all.html
new file mode 100644
index 0000000..deea6a6
--- /dev/null
+++ b/090/javadoc/index-all.html
@@ -0,0 +1,1315 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<!-- 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">
+<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)";
+ }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar_top">
+<!-- -->
+</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="./overview-summary.html">Overview</a></li>
+<li>Package</li>
+<li>Class</li>
+<li><a href="./overview-tree.html">Tree</a></li>
+<li><a href="./deprecated-list.html">Deprecated</a></li>
+<li class="navBarCell1Rev">Index</li>
+<li><a href="./help-doc.html">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="./index.html?index-all.html" target="_top">Frames</a></li>
+<li><a href="index-all.html" target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="./allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_top");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<a name="skip-navbar_top">
+<!-- -->
+</a></div>
+<!-- ========= END OF TOP NAVBAR ========= -->
+<div class="contentContainer"><a href="#_A_">A</a> <a href="#_B_">B</a> <a href="#_C_">C</a> <a href="#_D_">D</a> <a href="#_E_">E</a> <a href="#_F_">F</a> <a href="#_G_">G</a> <a href="#_H_">H</a> <a href="#_I_">I</a> <a href="#_K_">K</a> <a href="#_L_">L</a> <a href="#_M_">M</a> <a href="#_N_">N</a> <a href="#_O_">O</a> <a href="#_P_">P</a> <a href="#_R_">R</a> <a href="#_S_">S</a> <a href="#_T_">T</a> <a href="#_U_">U</a> <a href="#_V_">V</a> <a name="_A_">
+<!-- -->
+</a>
+<h2 class="title">A</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#ACKS_CONFIG">ACKS_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>acks</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#addRecord(org.apache.kafka.clients.consumer.ConsumerRecord)">addRecord(ConsumerRecord<K, V>)</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> </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>
+<dd> </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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.Throwable)">ApiException(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> </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> </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>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_OFFSET_RESET_CONFIG">AUTO_OFFSET_RESET_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.offset.reset</code></div>
+</dd>
+</dl>
+<a name="_B_">
+<!-- -->
+</a>
+<h2 class="title">B</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#BATCH_SIZE_CONFIG">BATCH_SIZE_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>batch.size</code></div>
+</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>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)">bootstrap(List<InetSocketAddress>)</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 a "bootstrap" cluster using the given list of host/ports</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#BOOTSTRAP_SERVERS_CONFIG">BOOTSTRAP_SERVERS_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>bootstrap.servers</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#BOOTSTRAP_SERVERS_CONFIG">BOOTSTRAP_SERVERS_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>bootstrap.servers</code></div>
+</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>
+</dd>
+<dt><a href="./org/apache/kafka/clients/producer/BufferExhaustedException.html" title="class in org.apache.kafka.clients.producer"><span class="strong">BufferExhaustedException</span></a> - Exception in <a href="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</a></dt>
+<dd>
+<div class="block">This exception is thrown if the producer is in non-blocking mode and the rate of data production exceeds the rate at
+ which data can be sent for long enough for the alloted buffer to be exhausted.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/BufferExhaustedException.html#BufferExhaustedException(java.lang.String)">BufferExhaustedException(String)</a></span> - Constructor for exception org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/BufferExhaustedException.html" title="class in org.apache.kafka.clients.producer">BufferExhaustedException</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">ByteArrayDeserializer</span></a> - Class in <a href="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#ByteArrayDeserializer()">ByteArrayDeserializer()</a></span> - Constructor for 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> </dd>
+<dt><a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">ByteArraySerializer</span></a> - Class in <a href="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html#ByteArraySerializer()">ByteArraySerializer()</a></span> - Constructor for 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> </dd>
+</dl>
+<a name="_C_">
+<!-- -->
+</a>
+<h2 class="title">C</h2>
+<dl>
+<dt><a href="./org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer"><span class="strong">Callback</span></a> - Interface in <a href="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</a></dt>
+<dd>
+<div class="block">A callback interface that the user can implement to allow code to execute when the request is complete.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#CHECK_CRCS_CONFIG">CHECK_CRCS_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>check.crcs</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#clear()">clear()</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">Clear the stored history of sent records</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#CLIENT_ID_CONFIG">CLIENT_ID_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>client.id</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#CLIENT_ID_CONFIG">CLIENT_ID_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>client.id</code></div>
+</dd>
+<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> </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> </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> </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/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> </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/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> </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> </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>
+<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>
+</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> </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> </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<Node>, Collection<PartitionInfo>)</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>
+<dd> </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<TopicPartition, Long>, 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>
+<dd> </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<TopicPartition, Long>, 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>
+<dd>
+<div class="block">Commits 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/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>
+<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>
+</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<TopicPartition, Long>, 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>
+<dd> </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>
+<dd> </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> </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
+ 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> </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> </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>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#COMPRESSION_TYPE_CONFIG">COMPRESSION_TYPE_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>compression.type</code></div>
+</dd>
+<dt><a href="./org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common"><span class="strong">Configurable</span></a> - Interface in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
+<dd>
+<div class="block">A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Configurable.html#configure(java.util.Map)">configure(Map<String, ?>)</a></span> - Method in interface org.apache.kafka.common.<a href="./org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a></dt>
+<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<String, ?>, 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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteArraySerializer.html#configure(java.util.Map, boolean)">configure(Map<String, ?>, 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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#configure(java.util.Map, boolean)">configure(Map<String, ?>, 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<String, ?>, 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<String, ?>, 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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringSerializer.html#configure(java.util.Map, boolean)">configure(Map<String, ?>, 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> </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><<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>> - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd> </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>
+<dd>
+<div class="block"><code>rebalance.callback.class</code></div>
+</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>
+<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>
+</dd>
+<dt><a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRecord</span></a><<a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="type parameter in ConsumerRecord">K</a>,<a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="type parameter in ConsumerRecord">V</a>> - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<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>
+<dd>
+<div class="block">Create a record with no key</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><<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>> - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd>
+<div class="block">A container that holds the list <a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer"><code>ConsumerRecord</code></a> per partition for a
+ particular topic.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#ConsumerRecords(java.util.Map)">ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>>)</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> </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
+ 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>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.String)">CorruptRecordException(String)</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> </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> </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>
+<dd> </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>
+<div class="block">The number of records for all topics</div>
+</dd>
+</dl>
+<a name="_D_">
+<!-- -->
+</a>
+<h2 class="title">D</h2>
+<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> </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>
+<dd> </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>
+<dd> </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>
+<dd> </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><<a href="./org/apache/kafka/common/serialization/Deserializer.html" title="type parameter in Deserializer">T</a>> - Interface in <a href="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</a></dt>
+<dd> </dd>
+</dl>
+<a name="_E_">
+<!-- -->
+</a>
+<h2 class="title">E</h2>
+<dl>
+<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>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#ENABLE_AUTO_COMMIT_CONFIG">ENABLE_AUTO_COMMIT_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>enable.auto.commit</code></div>
+</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> </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>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/TopicPartition.html#equals(java.lang.Object)">equals(Object)</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#errorNext(java.lang.RuntimeException)">errorNext(RuntimeException)</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 with the given error.</div>
+</dd>
+</dl>
+<a name="_F_">
+<!-- -->
+</a>
+<h2 class="title">F</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#FETCH_MAX_WAIT_MS_CONFIG">FETCH_MAX_WAIT_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>fetch.max.wait.ms</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#FETCH_MIN_BYTES_CONFIG">FETCH_MIN_BYTES_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>fetch.min.bytes</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#fillInStackTrace()">fillInStackTrace()</a></span> - Method in 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> </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> </dd>
+</dl>
+<a name="_G_">
+<!-- -->
+</a>
+<h2 class="title">G</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#group()">group()</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_ID_CONFIG">GROUP_ID_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>group.id</code></div>
+</dd>
+</dl>
+<a name="_H_">
+<!-- -->
+</a>
+<h2 class="title">H</h2>
+<dl>
+<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> </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> </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> </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>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Node.html#host()">host()</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">The host name for this node</div>
+</dd>
+</dl>
+<a name="_I_">
+<!-- -->
+</a>
+<h2 class="title">I</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Node.html#id()">id()</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">The node id of this node</div>
+</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/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>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException()">InvalidMetadataException()</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> </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> </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>
+<dd> </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> </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> </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>
+<dd> </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> </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> </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> </dd>
+</dl>
+<a name="_K_">
+<!-- -->
+</a>
+<h2 class="title">K</h2>
+<dl>
+<dt><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">KafkaConsumer</span></a><<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="type parameter in KafkaConsumer">K</a>,<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="type parameter in KafkaConsumer">V</a>> - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd>
+<div class="block">A Kafka client that consumes records from a Kafka cluster.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map)">KafkaConsumer(Map<String, Object>)</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.</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<String, Object>, ConsumerRebalanceCallback, 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 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>
+</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<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 <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>
+</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 href="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/KafkaException.html#KafkaException(java.lang.String)">KafkaException(String)</a></span> - Constructor for exception org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/KafkaException.html#KafkaException(java.lang.Throwable)">KafkaException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/KafkaException.html#KafkaException()">KafkaException()</a></span> - Constructor for exception org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer"><span class="strong">KafkaProducer</span></a><<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="type parameter in KafkaProducer">K</a>,<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="type parameter in KafkaProducer">V</a>> - Class in <a href="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</a></dt>
+<dd>
+<div class="block">A Kafka client that publishes records to the Kafka cluster.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#KafkaProducer(java.util.Map)">KafkaProducer(Map<String, Object>)</a></span> - Constructor for 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">A producer is instantiated by providing a set of key-value pairs as configuration.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#KafkaProducer(java.util.Map, org.apache.kafka.common.serialization.Serializer, org.apache.kafka.common.serialization.Serializer)">KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>)</a></span> - Constructor for 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">A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value <a href="./org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization"><code>Serializer</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#KafkaProducer(java.util.Properties)">KafkaProducer(Properties)</a></span> - Constructor for 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">A producer is instantiated by providing a set of key-value pairs as configuration.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#KafkaProducer(java.util.Properties, org.apache.kafka.common.serialization.Serializer, org.apache.kafka.common.serialization.Serializer)">KafkaProducer(Properties, Serializer<K>, Serializer<V>)</a></span> - Constructor for 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">A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value <a href="./org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization"><code>Serializer</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html#key()">key()</a></span> - Method in 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">The key (or null if no key is specified)</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerRecord.html#key()">key()</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>
+<div class="block">The key (or null if no key is specified)</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#KEY_DESERIALIZER_CLASS_CONFIG">KEY_DESERIALIZER_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>
+<dd>
+<div class="block"><code>key.deserializer</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#KEY_SERIALIZER_CLASS_CONFIG">KEY_SERIALIZER_CLASS_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>key.serializer</code></div>
+</dd>
+</dl>
+<a name="_L_">
+<!-- -->
+</a>
+<h2 class="title">L</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/common/PartitionInfo.html#leader()">leader()</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 node id of the node currently acting as a leader for this partition or -1 if there is no leader</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#leaderFor(org.apache.kafka.common.TopicPartition)">leaderFor(TopicPartition)</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 current leader for the given topic-partition</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/errors/LeaderNotAvailableException.html" title="class in org.apache.kafka.common.errors"><span class="strong">LeaderNotAvailableException</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">There is no currently available leader for the given partition (either because a leadership election is in progress
+ or because all replicas are down).</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/LeaderNotAvailableException.html#LeaderNotAvailableException(java.lang.String)">LeaderNotAvailableException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/LeaderNotAvailableException.html" title="class in org.apache.kafka.common.errors">LeaderNotAvailableException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#LINGER_MS_CONFIG">LINGER_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>linger.ms</code></div>
+</dd>
+</dl>
+<a name="_M_">
+<!-- -->
+</a>
+<h2 class="title">M</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#main(java.lang.String[])">main(String[])</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#main(java.lang.String[])">main(String[])</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION">MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION</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>max.in.flight.requests.per.connection</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#MAX_PARTITION_FETCH_BYTES_CONFIG">MAX_PARTITION_FETCH_BYTES_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>max.partition.fetch.bytes</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#MAX_REQUEST_SIZE_CONFIG">MAX_REQUEST_SIZE_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>max.request.size</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_FETCH_TIMEOUT_CONFIG">METADATA_FETCH_TIMEOUT_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>metadata.fetch.timeout.ms</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#METADATA_MAX_AGE_CONFIG">METADATA_MAX_AGE_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>metadata.max.age.ms</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_MAX_AGE_CONFIG">METADATA_MAX_AGE_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>metadata.max.age.ms</code></div>
+</dd>
+<dt><a href="./org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common"><span class="strong">Metric</span></a> - Interface in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
+<dd>
+<div class="block">A numerical metric tracked for monitoring purposes</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#METRIC_REPORTER_CLASSES_CONFIG">METRIC_REPORTER_CLASSES_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>metric.reporters</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METRIC_REPORTER_CLASSES_CONFIG">METRIC_REPORTER_CLASSES_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>metric.reporters</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Metric.html#metricName()">metricName()</a></span> - Method in interface org.apache.kafka.common.<a href="./org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a></dt>
+<dd>
+<div class="block">A name for this metric</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common"><span class="strong">MetricName</span></a> - Class in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
+<dd>
+<div class="block">The <code>MetricName</code> class encapsulates a metric's name, logical group and its related attributes</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.lang.String, java.util.Map)">MetricName(String, String, String, Map<String, String>)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.lang.String, java.lang.String...)">MetricName(String, String, String, String...)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.util.Map)">MetricName(String, String, Map<String, String>)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.lang.String)">MetricName(String, String, String)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String)">MetricName(String, String)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#metrics()">metrics()</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#metrics()">metrics()</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 metrics kept by the consumer</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#metrics()">metrics()</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#metrics()">metrics()</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#metrics()">metrics()</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> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#metrics()">metrics()</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">Return a map of metrics maintained by the producer</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#METRICS_NUM_SAMPLES_CONFIG">METRICS_NUM_SAMPLES_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>metrics.num.samples</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METRICS_NUM_SAMPLES_CONFIG">METRICS_NUM_SAMPLES_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>metrics.num.samples</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#METRICS_SAMPLE_WINDOW_MS_CONFIG">METRICS_SAMPLE_WINDOW_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>metrics.sample.window.ms</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METRICS_SAMPLE_WINDOW_MS_CONFIG">METRICS_SAMPLE_WINDOW_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>metrics.sample.window.ms</code></div>
+</dd>
+<dt><a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">MockConsumer</span></a><<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>> - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
+<dd>
+<div class="block">A mock of the <a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><code>Consumer</code></a> interface you can use for testing code that uses Kafka.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#MockConsumer()">MockConsumer()</a></span> - Constructor for 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> </dd>
+<dt><a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer"><span class="strong">MockProducer</span></a> - Class in <a href="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</a></dt>
+<dd>
+<div class="block">A mock of the producer interface you can use for testing code that uses Kafka.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer(org.apache.kafka.common.Cluster, boolean)">MockProducer(Cluster, boolean)</a></span> - Constructor for 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">Create a mock producer</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer(boolean)">MockProducer(boolean)</a></span> - Constructor for 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">Create a new mock producer with invented metadata the given autoComplete setting.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer()">MockProducer()</a></span> - Constructor for 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">Create a new auto completing mock producer
+
+ Equivalent to <a href="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer(boolean)"><code>new MockProducer(true)</code></a></div>
+</dd>
+</dl>
+<a name="_N_">
+<!-- -->
+</a>
+<h2 class="title">N</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#name()">name()</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> </dd>
+<dt><a href="./org/apache/kafka/common/errors/NetworkException.html" title="class in org.apache.kafka.common.errors"><span class="strong">NetworkException</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">A misc.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NetworkException.html#NetworkException()">NetworkException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NetworkException.html" title="class in org.apache.kafka.common.errors">NetworkException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NetworkException.html#NetworkException(java.lang.String, java.lang.Throwable)">NetworkException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NetworkException.html" title="class in org.apache.kafka.common.errors">NetworkException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NetworkException.html#NetworkException(java.lang.String)">NetworkException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NetworkException.html" title="class in org.apache.kafka.common.errors">NetworkException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NetworkException.html#NetworkException(java.lang.Throwable)">NetworkException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NetworkException.html" title="class in org.apache.kafka.common.errors">NetworkException</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common"><span class="strong">Node</span></a> - Class in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
+<dd>
+<div class="block">Information about a Kafka node</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Node.html#Node(int, java.lang.String, int)">Node(int, String, int)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#nodeById(int)">nodeById(int)</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 node by the node id (or null if no such node exists)</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#nodes()">nodes()</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> </dd>
+<dt><a href="./org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">NoOffsetForPartitionException</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">Indicates that there is no stored offset and no defined offset reset policy</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html#NoOffsetForPartitionException(java.lang.String)">NoOffsetForPartitionException(String)</a></span> - Constructor for exception org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html" title="class in org.apache.kafka.clients.consumer">NoOffsetForPartitionException</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors"><span class="strong">NotEnoughReplicasAfterAppendException</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">Number of insync replicas for the partition is lower than min.insync.replicas This exception is raised when the low
+ ISR size is discovered *after* the message was already appended to the log.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException()">NotEnoughReplicasAfterAppendException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasAfterAppendException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException(java.lang.String, java.lang.Throwable)">NotEnoughReplicasAfterAppendException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasAfterAppendException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException(java.lang.String)">NotEnoughReplicasAfterAppendException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasAfterAppendException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException(java.lang.Throwable)">NotEnoughReplicasAfterAppendException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasAfterAppendException</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors"><span class="strong">NotEnoughReplicasException</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">Number of insync replicas for the partition is lower than min.insync.replicas</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException()">NotEnoughReplicasException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException(java.lang.String, java.lang.Throwable)">NotEnoughReplicasException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException(java.lang.String)">NotEnoughReplicasException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException(java.lang.Throwable)">NotEnoughReplicasException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasException</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors"><span class="strong">NotLeaderForPartitionException</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 server is not the leader for the given partition</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException()">NotLeaderForPartitionException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors">NotLeaderForPartitionException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException(java.lang.String)">NotLeaderForPartitionException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors">NotLeaderForPartitionException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException(java.lang.Throwable)">NotLeaderForPartitionException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors">NotLeaderForPartitionException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException(java.lang.String, java.lang.Throwable)">NotLeaderForPartitionException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors">NotLeaderForPartitionException</a></dt>
+<dd> </dd>
+</dl>
+<a name="_O_">
+<!-- -->
+</a>
+<h2 class="title">O</h2>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html#offset()">offset()</a></span> - Method in 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">The position of this record in the corresponding Kafka partition.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/RecordMetadata.html#offset()">offset()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a></dt>
+<dd>
+<div class="block">The offset of the record in the topic/partition.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html" title="class in org.apache.kafka.common.errors"><span class="strong">OffsetMetadataTooLarge</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 tried to save its offset with associated metadata larger than the maximum size allowed by the server.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge()">OffsetMetadataTooLarge()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html" title="class in org.apache.kafka.common.errors">OffsetMetadataTooLarge</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge(java.lang.String)">OffsetMetadataTooLarge(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html" title="class in org.apache.kafka.common.errors">OffsetMetadataTooLarge</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge(java.lang.Throwable)">OffsetMetadataTooLarge(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html" title="class in org.apache.kafka.common.errors">OffsetMetadataTooLarge</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge(java.lang.String, java.lang.Throwable)">OffsetMetadataTooLarge(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html" title="class in org.apache.kafka.common.errors">OffsetMetadataTooLarge</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html" title="class in org.apache.kafka.common.errors"><span class="strong">OffsetOutOfRangeException</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 offset is either larger or smaller than the range of offsets the server has for the given partition.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html#OffsetOutOfRangeException()">OffsetOutOfRangeException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html" title="class in org.apache.kafka.common.errors">OffsetOutOfRangeException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html#OffsetOutOfRangeException(java.lang.String)">OffsetOutOfRangeException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/OffsetOu
<TRUNCATED>