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:40 UTC
[42/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/082/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/082/javadoc/index-all.html b/082/javadoc/index-all.html
new file mode 100644
index 0000000..07042ec
--- /dev/null
+++ b/082/javadoc/index-all.html
@@ -0,0 +1,864 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<!--NewPage-->
+<HTML>
+<HEAD>
+<!-- Generated by javadoc (build 1.6.0_65) on Wed Jan 28 22:31:45 CST 2015 -->
+<TITLE>
+Index (clients 0.8.2.0 API)
+</TITLE>
+
+<META NAME="date" CONTENT="2015-01-28">
+
+<LINK REL ="stylesheet" TYPE="text/css" HREF="./stylesheet.css" TITLE="Style">
+
+<SCRIPT type="text/javascript">
+function windowTitle()
+{
+ if (location.href.indexOf('is-external=true') == -1) {
+ parent.document.title="Index (clients 0.8.2.0 API)";
+ }
+}
+</SCRIPT>
+<NOSCRIPT>
+</NOSCRIPT>
+
+</HEAD>
+
+<BODY BGCOLOR="white" onload="windowTitle();">
+<HR>
+
+
+<!-- ========= START OF TOP NAVBAR ======= -->
+<A NAME="navbar_top"><!-- --></A>
+<A HREF="#skip-navbar_top" title="Skip navigation links"></A>
+<TABLE BORDER="0" WIDTH="100%" CELLPADDING="1" CELLSPACING="0" SUMMARY="">
+<TR>
+<TD COLSPAN=2 BGCOLOR="#EEEEFF" CLASS="NavBarCell1">
+<A NAME="navbar_top_firstrow"><!-- --></A>
+<TABLE BORDER="0" CELLPADDING="0" CELLSPACING="3" SUMMARY="">
+ <TR ALIGN="center" VALIGN="top">
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="./overview-summary.html"><FONT CLASS="NavBarFont1"><B>Overview</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <FONT CLASS="NavBarFont1">Package</FONT> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <FONT CLASS="NavBarFont1">Class</FONT> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="./overview-tree.html"><FONT CLASS="NavBarFont1"><B>Tree</B></FONT></A> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="./deprecated-list.html"><FONT CLASS="NavBarFont1"><B>Deprecated</B></FONT></A> </TD>
+ <TD BGCOLOR="#FFFFFF" CLASS="NavBarCell1Rev"> <FONT CLASS="NavBarFont1Rev"><B>Index</B></FONT> </TD>
+ <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="./help-doc.html"><FONT CLASS="NavBarFont1"><B>Help</B></FONT></A> </TD>
+ </TR>
+</TABLE>
+</TD>
+<TD ALIGN="right" VALIGN="top" ROWSPAN=3><EM>
+</EM>
+</TD>
+</TR>
+
+<TR>
+<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
+ PREV
+ NEXT</FONT></TD>
+<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
+ <A HREF="./index.html?index-all.html" target="_top"><B>FRAMES</B></A>
+ <A HREF="index-all.html" target="_top"><B>NO FRAMES</B></A>
+ <SCRIPT type="text/javascript">
+ <!--
+ if(window==top) {
+ document.writeln('<A HREF="./allclasses-noframe.html"><B>All Classes</B></A>');
+ }
+ //-->
+</SCRIPT>
+<NOSCRIPT>
+ <A HREF="./allclasses-noframe.html"><B>All Classes</B></A>
+</NOSCRIPT>
+
+
+</FONT></TD>
+</TR>
+</TABLE>
+<A NAME="skip-navbar_top"></A>
+<!-- ========= END OF TOP NAVBAR ========= -->
+
+<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> <HR>
+<A NAME="_A_"><!-- --></A><H2>
+<B>A</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#ACKS_CONFIG"><B>ACKS_CONFIG</B></A> -
+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>
+<DD><code>acks</code>
+<DT><A HREF="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors"><B>ApiException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>Any API exception that is part of the public protocol and should be a subclass of this class and be part of this
+ package.<DT><A HREF="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.String, java.lang.Throwable)"><B>ApiException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.String)"><B>ApiException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.Throwable)"><B>ApiException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/ApiException.html#ApiException()"><B>ApiException()</B></A> -
+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>
+<DD>
+</DL>
+<HR>
+<A NAME="_B_"><!-- --></A><H2>
+<B>B</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#BATCH_SIZE_CONFIG"><B>BATCH_SIZE_CONFIG</B></A> -
+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>
+<DD><code>batch.size</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#BLOCK_ON_BUFFER_FULL_CONFIG"><B>BLOCK_ON_BUFFER_FULL_CONFIG</B></A> -
+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>
+<DD><code>block.on.buffer.full</code>
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)"><B>bootstrap(List<InetSocketAddress>)</B></A> -
+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>
+<DD>Create a "bootstrap" cluster using the given list of host/ports
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#BOOTSTRAP_SERVERS_CONFIG"><B>BOOTSTRAP_SERVERS_CONFIG</B></A> -
+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>
+<DD><code>bootstrap.servers</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#BUFFER_MEMORY_CONFIG"><B>BUFFER_MEMORY_CONFIG</B></A> -
+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>
+<DD><code>buffer.memory</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/BufferExhaustedException.html" title="class in org.apache.kafka.clients.producer"><B>BufferExhaustedException</B></A> - Exception in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>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.<DT><A HREF="./org/apache/kafka/clients/producer/BufferExhaustedException.html#BufferExhaustedException(java.lang.String)"><B>BufferExhaustedException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html" title="class in org.apache.kafka.common.serialization"><B>ByteArrayDeserializer</B></A> - Class in <A HREF="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</A><DD> <DT><A HREF="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#ByteArrayDeserializer()"><B>ByteArrayDeserializer()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArraySerializer.html" title="class in org.apache.kafka.common.serialization"><B>ByteArraySerializer</B></A> - Class in <A HREF="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</A><DD> <DT><A HREF="./org/apache/kafka/common/serialization/ByteArraySerializer.html#ByteArraySerializer()"><B>ByteArraySerializer()</B></A> -
+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>
+<DD>
+</DL>
+<HR>
+<A NAME="_C_"><!-- --></A><H2>
+<B>C</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer"><B>Callback</B></A> - Interface in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>A callback interface that the user can implement to allow code to execute when the request is complete.<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#clear()"><B>clear()</B></A> -
+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>
+<DD>Clear the stored history of sent records
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#CLIENT_ID_CONFIG"><B>CLIENT_ID_CONFIG</B></A> -
+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>
+<DD><code>client.id</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#close()"><B>close()</B></A> -
+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>
+<DD>Close this producer.
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#close()"><B>close()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/Producer.html#close()"><B>close()</B></A> -
+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>
+<DD>Close this producer
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#close()"><B>close()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArraySerializer.html#close()"><B>close()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/Deserializer.html#close()"><B>close()</B></A> -
+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>
+<DD>Close this deserializer
+<DT><A HREF="./org/apache/kafka/common/serialization/Serializer.html#close()"><B>close()</B></A> -
+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>
+<DD>Close this serializer
+<DT><A HREF="./org/apache/kafka/common/serialization/StringDeserializer.html#close()"><B>close()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/StringSerializer.html#close()"><B>close()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common"><B>Cluster</B></A> - Class in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>A representation of a subset of the nodes, topics, and partitions in the Kafka cluster.<DT><A HREF="./org/apache/kafka/common/Cluster.html#Cluster(java.util.Collection, java.util.Collection)"><B>Cluster(Collection<Node>, Collection<PartitionInfo>)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>Create a new cluster with the given nodes and partitions
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#completeNext()"><B>completeNext()</B></A> -
+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>
+<DD>Complete the earliest uncompleted call successfully.
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#COMPRESSION_TYPE_CONFIG"><B>COMPRESSION_TYPE_CONFIG</B></A> -
+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>
+<DD><code>compression.type</code>
+<DT><A HREF="./org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common"><B>Configurable</B></A> - Interface in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters<DT><A HREF="./org/apache/kafka/common/Configurable.html#configure(java.util.Map)"><B>configure(Map<String, ?>)</B></A> -
+Method in interface org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</A>
+<DD>Configure this class with the given key-value pairs
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#configure(java.util.Map, boolean)"><B>configure(Map<String, ?>, boolean)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArraySerializer.html#configure(java.util.Map, boolean)"><B>configure(Map<String, ?>, boolean)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/Deserializer.html#configure(java.util.Map, boolean)"><B>configure(Map<String, ?>, boolean)</B></A> -
+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>
+<DD>Configure this class.
+<DT><A HREF="./org/apache/kafka/common/serialization/Serializer.html#configure(java.util.Map, boolean)"><B>configure(Map<String, ?>, boolean)</B></A> -
+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>
+<DD>Configure this class.
+<DT><A HREF="./org/apache/kafka/common/serialization/StringDeserializer.html#configure(java.util.Map, boolean)"><B>configure(Map<String, ?>, boolean)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/StringSerializer.html#configure(java.util.Map, boolean)"><B>configure(Map<String, ?>, boolean)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors"><B>CorruptRecordException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>This exception indicates a record has failed it's internal CRC check, this generally indicates network or disk
+ corruption.<DT><A HREF="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException()"><B>CorruptRecordException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.String)"><B>CorruptRecordException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.Throwable)"><B>CorruptRecordException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException(java.lang.String, java.lang.Throwable)"><B>CorruptRecordException(String, Throwable)</B></A> -
+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>
+<DD>
+</DL>
+<HR>
+<A NAME="_D_"><!-- --></A><H2>
+<B>D</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#description()"><B>description()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArrayDeserializer.html#deserialize(java.lang.String, byte[])"><B>deserialize(String, byte[])</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/Deserializer.html#deserialize(java.lang.String, byte[])"><B>deserialize(String, byte[])</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/StringDeserializer.html#deserialize(java.lang.String, byte[])"><B>deserialize(String, byte[])</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization"><B>Deserializer</B></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><DD> </DL>
+<HR>
+<A NAME="_E_"><!-- --></A><H2>
+<B>E</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#empty()"><B>empty()</B></A> -
+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>
+<DD>Create an empty cluster instance with no nodes and no topic-partitions.
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#equals(java.lang.Object)"><B>equals(Object)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Node.html#equals(java.lang.Object)"><B>equals(Object)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/TopicPartition.html#equals(java.lang.Object)"><B>equals(Object)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#errorNext(java.lang.RuntimeException)"><B>errorNext(RuntimeException)</B></A> -
+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>
+<DD>Complete the earliest uncompleted call with the given error.
+</DL>
+<HR>
+<A NAME="_F_"><!-- --></A><H2>
+<B>F</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/errors/ApiException.html#fillInStackTrace()"><B>fillInStackTrace()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/SerializationException.html#fillInStackTrace()"><B>fillInStackTrace()</B></A> -
+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>
+<DD>
+</DL>
+<HR>
+<A NAME="_G_"><!-- --></A><H2>
+<B>G</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#group()"><B>group()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+</DL>
+<HR>
+<A NAME="_H_"><!-- --></A><H2>
+<B>H</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#hashCode()"><B>hashCode()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Node.html#hashCode()"><B>hashCode()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/TopicPartition.html#hashCode()"><B>hashCode()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#history()"><B>history()</B></A> -
+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>
+<DD>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>
+<DT><A HREF="./org/apache/kafka/common/Node.html#host()"><B>host()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>The host name for this node
+</DL>
+<HR>
+<A NAME="_I_"><!-- --></A><H2>
+<B>I</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/Node.html#id()"><B>id()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>The node id of this node
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#inSyncReplicas()"><B>inSyncReplicas()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</A>
+<DD>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
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidMetadataException.html" title="class in org.apache.kafka.common.errors"><B>InvalidMetadataException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>An exception that may indicate the client's metadata is out of date<DT><A HREF="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException()"><B>InvalidMetadataException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.String)"><B>InvalidMetadataException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.String, java.lang.Throwable)"><B>InvalidMetadataException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidMetadataException.html#InvalidMetadataException(java.lang.Throwable)"><B>InvalidMetadataException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors"><B>InvalidTopicException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>The client has attempted to perform an operation on an invalid topic.<DT><A HREF="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException()"><B>InvalidTopicException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.String, java.lang.Throwable)"><B>InvalidTopicException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.String)"><B>InvalidTopicException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/InvalidTopicException.html#InvalidTopicException(java.lang.Throwable)"><B>InvalidTopicException(Throwable)</B></A> -
+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>
+<DD>
+</DL>
+<HR>
+<A NAME="_K_"><!-- --></A><H2>
+<B>K</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common"><B>KafkaException</B></A> - Exception in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>The base class of all other Kafka exceptions<DT><A HREF="./org/apache/kafka/common/KafkaException.html#KafkaException(java.lang.String, java.lang.Throwable)"><B>KafkaException(String, Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.<A HREF="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/KafkaException.html#KafkaException(java.lang.String)"><B>KafkaException(String)</B></A> -
+Constructor for exception org.apache.kafka.common.<A HREF="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/KafkaException.html#KafkaException(java.lang.Throwable)"><B>KafkaException(Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.<A HREF="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/KafkaException.html#KafkaException()"><B>KafkaException()</B></A> -
+Constructor for exception org.apache.kafka.common.<A HREF="./org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer"><B>KafkaProducer</B></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><DD>A Kafka client that publishes records to the Kafka cluster.<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#KafkaProducer(java.util.Map)"><B>KafkaProducer(Map<String, Object>)</B></A> -
+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>
+<DD>A producer is instantiated by providing a set of key-value pairs as configuration.
+<DT><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)"><B>KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>)</B></A> -
+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>
+<DD>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>.
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#KafkaProducer(java.util.Properties)"><B>KafkaProducer(Properties)</B></A> -
+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>
+<DD>A producer is instantiated by providing a set of key-value pairs as configuration.
+<DT><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)"><B>KafkaProducer(Properties, Serializer<K>, Serializer<V>)</B></A> -
+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>
+<DD>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>.
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#key()"><B>key()</B></A> -
+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>
+<DD>The key (or null if no key is specified)
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#KEY_SERIALIZER_CLASS_CONFIG"><B>KEY_SERIALIZER_CLASS_CONFIG</B></A> -
+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>
+<DD><code>key.serializer</code>
+</DL>
+<HR>
+<A NAME="_L_"><!-- --></A><H2>
+<B>L</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#leader()"><B>leader()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</A>
+<DD>The node id of the node currently acting as a leader for this partition or -1 if there is no leader
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#leaderFor(org.apache.kafka.common.TopicPartition)"><B>leaderFor(TopicPartition)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>Get the current leader for the given topic-partition
+<DT><A HREF="./org/apache/kafka/common/errors/LeaderNotAvailableException.html" title="class in org.apache.kafka.common.errors"><B>LeaderNotAvailableException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>There is no currently available leader for the given partition (either because a leadership election is in progress
+ or because all replicas are down).<DT><A HREF="./org/apache/kafka/common/errors/LeaderNotAvailableException.html#LeaderNotAvailableException(java.lang.String)"><B>LeaderNotAvailableException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#LINGER_MS_CONFIG"><B>LINGER_MS_CONFIG</B></A> -
+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>
+<DD><code>linger.ms</code>
+</DL>
+<HR>
+<A NAME="_M_"><!-- --></A><H2>
+<B>M</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#main(java.lang.String[])"><B>main(String[])</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION"><B>MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION</B></A> -
+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>
+<DD><code>max.in.flight.requests.per.connection</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#MAX_REQUEST_SIZE_CONFIG"><B>MAX_REQUEST_SIZE_CONFIG</B></A> -
+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>
+<DD><code>max.request.size</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_FETCH_TIMEOUT_CONFIG"><B>METADATA_FETCH_TIMEOUT_CONFIG</B></A> -
+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>
+<DD><code>metadata.fetch.timeout.ms</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_MAX_AGE_CONFIG"><B>METADATA_MAX_AGE_CONFIG</B></A> -
+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>
+<DD><code>metadata.max.age.ms</code>
+<DT><A HREF="./org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common"><B>Metric</B></A> - Interface in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>A numerical metric tracked for monitoring purposes<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#METRIC_REPORTER_CLASSES_CONFIG"><B>METRIC_REPORTER_CLASSES_CONFIG</B></A> -
+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>
+<DD><code>metric.reporters</code>
+<DT><A HREF="./org/apache/kafka/common/Metric.html#metricName()"><B>metricName()</B></A> -
+Method in interface org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</A>
+<DD>A name for this metric
+<DT><A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common"><B>MetricName</B></A> - Class in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>The <code>MetricName</code> class encapsulates a metric's name, logical group and its related attributes<DT><A HREF="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.lang.String, java.util.Map)"><B>MetricName(String, String, String, Map<String, String>)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.lang.String, java.lang.String...)"><B>MetricName(String, String, String, String...)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.util.Map)"><B>MetricName(String, String, Map<String, String>)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String, java.lang.String)"><B>MetricName(String, String, String)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#MetricName(java.lang.String, java.lang.String)"><B>MetricName(String, String)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#metrics()"><B>metrics()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#metrics()"><B>metrics()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/Producer.html#metrics()"><B>metrics()</B></A> -
+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>
+<DD>Return a map of metrics maintained by the producer
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#METRICS_NUM_SAMPLES_CONFIG"><B>METRICS_NUM_SAMPLES_CONFIG</B></A> -
+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>
+<DD><code>metrics.num.samples</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#METRICS_SAMPLE_WINDOW_MS_CONFIG"><B>METRICS_SAMPLE_WINDOW_MS_CONFIG</B></A> -
+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>
+<DD><code>metrics.sample.window.ms</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer"><B>MockProducer</B></A> - Class in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>A mock of the producer interface you can use for testing code that uses Kafka.<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer(org.apache.kafka.common.Cluster, boolean)"><B>MockProducer(Cluster, boolean)</B></A> -
+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>
+<DD>Create a mock producer
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer(boolean)"><B>MockProducer(boolean)</B></A> -
+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>
+<DD>Create a new mock producer with invented metadata the given autoComplete setting.
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#MockProducer()"><B>MockProducer()</B></A> -
+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>
+<DD>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>
+</DL>
+<HR>
+<A NAME="_N_"><!-- --></A><H2>
+<B>N</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#name()"><B>name()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NetworkException.html" title="class in org.apache.kafka.common.errors"><B>NetworkException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>A misc.<DT><A HREF="./org/apache/kafka/common/errors/NetworkException.html#NetworkException()"><B>NetworkException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NetworkException.html#NetworkException(java.lang.String, java.lang.Throwable)"><B>NetworkException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NetworkException.html#NetworkException(java.lang.String)"><B>NetworkException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NetworkException.html#NetworkException(java.lang.Throwable)"><B>NetworkException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common"><B>Node</B></A> - Class in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>Information about a Kafka node<DT><A HREF="./org/apache/kafka/common/Node.html#Node(int, java.lang.String, int)"><B>Node(int, String, int)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#nodes()"><B>nodes()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors"><B>NotEnoughReplicasAfterAppendException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>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.<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException()"><B>NotEnoughReplicasAfterAppendException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException(java.lang.String, java.lang.Throwable)"><B>NotEnoughReplicasAfterAppendException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException(java.lang.String)"><B>NotEnoughReplicasAfterAppendException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html#NotEnoughReplicasAfterAppendException(java.lang.Throwable)"><B>NotEnoughReplicasAfterAppendException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors"><B>NotEnoughReplicasException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>Number of insync replicas for the partition is lower than min.insync.replicas<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException()"><B>NotEnoughReplicasException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException(java.lang.String, java.lang.Throwable)"><B>NotEnoughReplicasException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException(java.lang.String)"><B>NotEnoughReplicasException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotEnoughReplicasException.html#NotEnoughReplicasException(java.lang.Throwable)"><B>NotEnoughReplicasException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors"><B>NotLeaderForPartitionException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>This server is not the leader for the given partition<DT><A HREF="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException()"><B>NotLeaderForPartitionException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException(java.lang.String)"><B>NotLeaderForPartitionException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException(java.lang.Throwable)"><B>NotLeaderForPartitionException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/NotLeaderForPartitionException.html#NotLeaderForPartitionException(java.lang.String, java.lang.Throwable)"><B>NotLeaderForPartitionException(String, Throwable)</B></A> -
+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>
+<DD>
+</DL>
+<HR>
+<A NAME="_O_"><!-- --></A><H2>
+<B>O</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/RecordMetadata.html#offset()"><B>offset()</B></A> -
+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>
+<DD>The offset of the record in the topic/partition.
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html" title="class in org.apache.kafka.common.errors"><B>OffsetMetadataTooLarge</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server.<DT><A HREF="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge()"><B>OffsetMetadataTooLarge()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge(java.lang.String)"><B>OffsetMetadataTooLarge(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge(java.lang.Throwable)"><B>OffsetMetadataTooLarge(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetMetadataTooLarge.html#OffsetMetadataTooLarge(java.lang.String, java.lang.Throwable)"><B>OffsetMetadataTooLarge(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html" title="class in org.apache.kafka.common.errors"><B>OffsetOutOfRangeException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>This offset is either larger or smaller than the range of offsets the server has for the given partition.<DT><A HREF="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html#OffsetOutOfRangeException()"><B>OffsetOutOfRangeException()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html#OffsetOutOfRangeException(java.lang.String)"><B>OffsetOutOfRangeException(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html#OffsetOutOfRangeException(java.lang.Throwable)"><B>OffsetOutOfRangeException(Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/OffsetOutOfRangeException.html#OffsetOutOfRangeException(java.lang.String, java.lang.Throwable)"><B>OffsetOutOfRangeException(String, Throwable)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/Callback.html#onCompletion(org.apache.kafka.clients.producer.RecordMetadata, java.lang.Exception)"><B>onCompletion(RecordMetadata, Exception)</B></A> -
+Method in interface org.apache.kafka.clients.producer.<A HREF="./org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</A>
+<DD>A callback method the user can implement to provide asynchronous handling of request completion.
+<DT><A HREF="./org/apache/kafka/clients/producer/package-summary.html"><B>org.apache.kafka.clients.producer</B></A> - package org.apache.kafka.clients.producer<DD> <DT><A HREF="./org/apache/kafka/common/package-summary.html"><B>org.apache.kafka.common</B></A> - package org.apache.kafka.common<DD> <DT><A HREF="./org/apache/kafka/common/errors/package-summary.html"><B>org.apache.kafka.common.errors</B></A> - package org.apache.kafka.common.errors<DD> <DT><A HREF="./org/apache/kafka/common/serialization/package-summary.html"><B>org.apache.kafka.common.serialization</B></A> - package org.apache.kafka.common.serialization<DD> </DL>
+<HR>
+<A NAME="_P_"><!-- --></A><H2>
+<B>P</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#partition()"><B>partition()</B></A> -
+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>
+<DD>The partition to which the record will be sent (or null if no partition was specified)
+<DT><A HREF="./org/apache/kafka/clients/producer/RecordMetadata.html#partition()"><B>partition()</B></A> -
+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>
+<DD>The partition the record was sent to
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#partition(org.apache.kafka.common.TopicPartition)"><B>partition(TopicPartition)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>Get the metadata for the specified partition
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#partition()"><B>partition()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</A>
+<DD>The partition id
+<DT><A HREF="./org/apache/kafka/common/TopicPartition.html#partition()"><B>partition()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common"><B>PartitionInfo</B></A> - Class in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>Information about a topic-partition.<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#PartitionInfo(java.lang.String, int, org.apache.kafka.common.Node, org.apache.kafka.common.Node[], org.apache.kafka.common.Node[])"><B>PartitionInfo(String, int, Node, Node[], Node[])</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#partitionsFor(java.lang.String)"><B>partitionsFor(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#partitionsFor(java.lang.String)"><B>partitionsFor(String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/Producer.html#partitionsFor(java.lang.String)"><B>partitionsFor(String)</B></A> -
+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>
+<DD>Get a list of partitions for the given topic for custom partition assignment.
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#partitionsForNode(int)"><B>partitionsForNode(int)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>Get the list of partitions whose leader is this node
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#partitionsForTopic(java.lang.String)"><B>partitionsForTopic(String)</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>Get the list of partitions for this topic
+<DT><A HREF="./org/apache/kafka/common/Node.html#port()"><B>port()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>The port for this node
+<DT><A HREF="./org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer"><B>Producer</B></A><<A HREF="./org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</A>,<A HREF="./org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</A>> - Interface in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>The interface for the <A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer"><CODE>KafkaProducer</CODE></A><DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer"><B>ProducerConfig</B></A> - Class in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>Configuration for the Kafka Producer.<DT><A HREF="./org/apache/kafka/clients/producer/Produc
erRecord.html" title="class in org.apache.kafka.clients.producer"><B>ProducerRecord</B></A><<A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html" title="type parameter in ProducerRecord">K</A>,<A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html" title="type parameter in ProducerRecord">V</A>> - Class in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>A key/value pair to be sent to Kafka.<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#ProducerRecord(java.lang.String, java.lang.Integer, K, V)"><B>ProducerRecord(String, Integer, K, V)</B></A> -
+Constructor for 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>
+<DD>Creates a record to be sent to a specified topic and partition
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#ProducerRecord(java.lang.String, K, V)"><B>ProducerRecord(String, K, V)</B></A> -
+Constructor for 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>
+<DD>Create a record to be sent to Kafka
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#ProducerRecord(java.lang.String, V)"><B>ProducerRecord(String, V)</B></A> -
+Constructor for 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>
+<DD>Create a record with no key
+</DL>
+<HR>
+<A NAME="_R_"><!-- --></A><H2>
+<B>R</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#RECEIVE_BUFFER_CONFIG"><B>RECEIVE_BUFFER_CONFIG</B></A> -
+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>
+<DD><code>receive.buffer.bytes</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#RECONNECT_BACKOFF_MS_CONFIG"><B>RECONNECT_BACKOFF_MS_CONFIG</B></A> -
+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>
+<DD><code>reconnect.backoff.ms</code>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors"><B>RecordBatchTooLargeException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>This record batch is larger than the maximum allowable size<DT><A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html#RecordBatchTooLargeException()"><B>RecordBatchTooLargeException()</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordBatchTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html#RecordBatchTooLargeException(java.lang.String, java.lang.Throwable)"><B>RecordBatchTooLargeException(String, Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordBatchTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html#RecordBatchTooLargeException(java.lang.String)"><B>RecordBatchTooLargeException(String)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordBatchTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html#RecordBatchTooLargeException(java.lang.Throwable)"><B>RecordBatchTooLargeException(Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordBatchTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer"><B>RecordMetadata</B></A> - Class in <A HREF="./org/apache/kafka/clients/producer/package-summary.html">org.apache.kafka.clients.producer</A><DD>The metadata for a record that has been acknowledged by the server<DT><A HREF="./org/apache/kafka/clients/producer/RecordMetadata.html#RecordMetadata(org.apache.kafka.common.TopicPartition, long, long)"><B>RecordMetadata(TopicPartition, long, long)</B></A> -
+Constructor for 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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors"><B>RecordTooLargeException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>This record is larger than the maximum allowable size<DT><A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html#RecordTooLargeException()"><B>RecordTooLargeException()</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html#RecordTooLargeException(java.lang.String, java.lang.Throwable)"><B>RecordTooLargeException(String, Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html#RecordTooLargeException(java.lang.String)"><B>RecordTooLargeException(String)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html#RecordTooLargeException(java.lang.Throwable)"><B>RecordTooLargeException(Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordTooLargeException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#replicas()"><B>replicas()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</A>
+<DD>The complete set of replicas for this partition regardless of whether they are alive or up-to-date
+<DT><A HREF="./org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors"><B>RetriableException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>A retryable exception is a transient exception that if retried may succeed.<DT><A HREF="./org/apache/kafka/common/errors/RetriableException.html#RetriableException(java.lang.String, java.lang.Throwable)"><B>RetriableException(String, Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors">RetriableException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RetriableException.html#RetriableException(java.lang.String)"><B>RetriableException(String)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors">RetriableException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RetriableException.html#RetriableException(java.lang.Throwable)"><B>RetriableException(Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors">RetriableException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/RetriableException.html#RetriableException()"><B>RetriableException()</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors">RetriableException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#RETRIES_CONFIG"><B>RETRIES_CONFIG</B></A> -
+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>
+<DD><code>retries</code>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#RETRY_BACKOFF_MS_CONFIG"><B>RETRY_BACKOFF_MS_CONFIG</B></A> -
+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>
+<DD><code>retry.backoff.ms</code>
+</DL>
+<HR>
+<A NAME="_S_"><!-- --></A><H2>
+<B>S</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord)"><B>send(ProducerRecord<K, V>)</B></A> -
+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>
+<DD>Asynchronously send a record to a topic.
+<DT><A HREF="./org/apache/kafka/clients/producer/KafkaProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord, org.apache.kafka.clients.producer.Callback)"><B>send(ProducerRecord<K, V>, Callback)</B></A> -
+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>
+<DD>Asynchronously send a record to a topic and invoke the provided callback when the send has been acknowledged.
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord)"><B>send(ProducerRecord<byte[], byte[]>)</B></A> -
+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>
+<DD>Adds the record to the list of sent records.
+<DT><A HREF="./org/apache/kafka/clients/producer/MockProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord, org.apache.kafka.clients.producer.Callback)"><B>send(ProducerRecord<byte[], byte[]>, Callback)</B></A> -
+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>
+<DD>Adds the record to the list of sent records.
+<DT><A HREF="./org/apache/kafka/clients/producer/Producer.html#send(org.apache.kafka.clients.producer.ProducerRecord)"><B>send(ProducerRecord<K, V>)</B></A> -
+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>
+<DD>Send the given record asynchronously and return a future which will eventually contain the response information.
+<DT><A HREF="./org/apache/kafka/clients/producer/Producer.html#send(org.apache.kafka.clients.producer.ProducerRecord, org.apache.kafka.clients.producer.Callback)"><B>send(ProducerRecord<K, V>, Callback)</B></A> -
+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>
+<DD>Send a record and invoke the given callback when the record has been acknowledged by the server
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#SEND_BUFFER_CONFIG"><B>SEND_BUFFER_CONFIG</B></A> -
+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>
+<DD><code>send.buffer.bytes</code>
+<DT><A HREF="./org/apache/kafka/common/errors/SerializationException.html" title="class in org.apache.kafka.common.errors"><B>SerializationException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>Any exception during serialization in the producer<DT><A HREF="./org/apache/kafka/common/errors/SerializationException.html#SerializationException(java.lang.String, java.lang.Throwable)"><B>SerializationException(String, Throwable)</B></A> -
+Constructor for 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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/SerializationException.html#SerializationException(java.lang.String)"><B>SerializationException(String)</B></A> -
+Constructor for 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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/SerializationException.html#SerializationException(java.lang.Throwable)"><B>SerializationException(Throwable)</B></A> -
+Constructor for 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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/SerializationException.html#SerializationException()"><B>SerializationException()</B></A> -
+Constructor for 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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/ByteArraySerializer.html#serialize(java.lang.String, byte[])"><B>serialize(String, byte[])</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/Serializer.html#serialize(java.lang.String, T)"><B>serialize(String, T)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/StringSerializer.html#serialize(java.lang.String, java.lang.String)"><B>serialize(String, String)</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization"><B>Serializer</B></A><<A HREF="./org/apache/kafka/common/serialization/Serializer.html" title="type parameter in Serializer">T</A>> - Interface in <A HREF="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</A><DD> <DT><A HREF="./org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization"><B>StringDeserializer</B></A> - Class in <A HREF="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</A><DD>String encoding defaults to UTF8 and can be customized by setting the property key.deserializer.encoding,
+ value.deserializer.encoding or deserializer.encoding.<DT><A HREF="./org/apache/kafka/common/serialization/StringDeserializer.html#StringDeserializer()"><B>StringDeserializer()</B></A> -
+Constructor for 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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization"><B>StringSerializer</B></A> - Class in <A HREF="./org/apache/kafka/common/serialization/package-summary.html">org.apache.kafka.common.serialization</A><DD>String encoding defaults to UTF8 and can be customized by setting the property key.serializer.encoding,
+ value.serializer.encoding or serializer.encoding.<DT><A HREF="./org/apache/kafka/common/serialization/StringSerializer.html#StringSerializer()"><B>StringSerializer()</B></A> -
+Constructor for 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>
+<DD>
+</DL>
+<HR>
+<A NAME="_T_"><!-- --></A><H2>
+<B>T</B></H2>
+<DL>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#tags()"><B>tags()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerConfig.html#TIMEOUT_CONFIG"><B>TIMEOUT_CONFIG</B></A> -
+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>
+<DD><code>timeout.ms</code>
+<DT><A HREF="./org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors"><B>TimeoutException</B></A> - Exception in <A HREF="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</A><DD>Indicates that a request timed out.<DT><A HREF="./org/apache/kafka/common/errors/TimeoutException.html#TimeoutException()"><B>TimeoutException()</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/TimeoutException.html#TimeoutException(java.lang.String, java.lang.Throwable)"><B>TimeoutException(String, Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/TimeoutException.html#TimeoutException(java.lang.String)"><B>TimeoutException(String)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/errors/TimeoutException.html#TimeoutException(java.lang.Throwable)"><B>TimeoutException(Throwable)</B></A> -
+Constructor for exception org.apache.kafka.common.errors.<A HREF="./org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#topic()"><B>topic()</B></A> -
+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>
+<DD>The topic this record is being sent to
+<DT><A HREF="./org/apache/kafka/clients/producer/RecordMetadata.html#topic()"><B>topic()</B></A> -
+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>
+<DD>The topic the record was appended to
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#topic()"><B>topic()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</A>
+<DD>The topic name
+<DT><A HREF="./org/apache/kafka/common/TopicPartition.html#topic()"><B>topic()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common"><B>TopicPartition</B></A> - Class in <A HREF="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</A><DD>A topic name and partition number<DT><A HREF="./org/apache/kafka/common/TopicPartition.html#TopicPartition(java.lang.String, int)"><B>TopicPartition(String, int)</B></A> -
+Constructor for class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#topics()"><B>topics()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>Get all topics.
+<DT><A HREF="./org/apache/kafka/clients/producer/ProducerRecord.html#toString()"><B>toString()</B></A> -
+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>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Cluster.html#toString()"><B>toString()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/MetricName.html#toString()"><B>toString()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/Node.html#toString()"><B>toString()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common">Node</A>
+<DD>
+<DT><A HREF="./org/apache/kafka/common/PartitionInfo.html#toString()"><B>toString()</B></A> -
+Method in class org.apache.kafka.common.<A HREF="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apa
<TRUNCATED>