http://git-wip-us.apache.org/repos/asf/kafka-site/blob/b91f7909/0100/javadoc/index-all.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/index-all.html b/0100/javadoc/index-all.html index d57397c..71b5afb 100644 --- a/0100/javadoc/index-all.html +++ b/0100/javadoc/index-all.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 29 16:30:04 PDT 2016 --> -<title>Index (core 0.10.0.0 API)</title> -<meta name="date" content="2016-04-29"> +<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:38 PDT 2016 --> +<title>Index (clients 0.10.0.0 API)</title> +<meta name="date" content="2016-05-17"> <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 (core 0.10.0.0 API)"; + parent.document.title="Index (clients 0.10.0.0 API)"; } //--> </script> @@ -24,7 +24,8 @@ <!-- --> </a> <ul class="navList" title="Navigation"> -<li><a href="./kafka/javaapi/consumer/package-summary.html">Package</a></li> +<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> @@ -60,82 +61,2542 @@ <!-- --> </a></div> <!-- ========= END OF TOP NAVBAR ========= --> -<div class="contentContainer"><a href="#_B_">B</a> <a href="#_C_">C</a> <a href="#_K_">K</a> <a href="#_S_">S</a> <a name="_B_"> +<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 href="#_W_">W</a> <a name="_A_"> +<!-- --> +</a> +<h2 class="title">A</h2> +<dl> +<dt><a href="./org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config"><span class="strong">AbstractConfig</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">A convenient base class for configurations to extend.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig(org.apache.kafka.common.config.ConfigDef,%20java.util.Map,%20boolean)">AbstractConfig(ConfigDef, Map<?, ?>, boolean)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config">AbstractConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig(org.apache.kafka.common.config.ConfigDef,%20java.util.Map)">AbstractConfig(ConfigDef, Map<?, ?>)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config">AbstractConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig(java.util.Map)">AbstractConfig(Map<String, Object>)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config">AbstractConfig</a></dt> +<dd> </dd> +<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/common/config/SaslConfigs.html#addClientSaslSupport(org.apache.kafka.common.config.ConfigDef)">addClientSaslSupport(ConfigDef)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#addClientSslSupport(org.apache.kafka.common.config.ConfigDef)">addClientSslSupport(ConfigDef)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig(java.util.Map,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">addDeserializerToConfig(Map<String, Object>, Deserializer<?>, Deserializer<?>)</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/consumer/ConsumerConfig.html#addDeserializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">addDeserializerToConfig(Properties, Deserializer<?>, Deserializer<?>)</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/common/config/ConfigValue.html#addErrorMessage(java.lang.String)">addErrorMessage(String)</a></span> - Method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config">ConfigValue</a></dt> +<dd> </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><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig(java.util.Map,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Map<String, Object>, Serializer<?>, Serializer<?>)</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#addSerializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Properties, Serializer<?>, Serializer<?>)</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/consumer/RoundRobinAssignor.html#allPartitionsSorted(java.util.Map,%20java.util.Map)">allPartitionsSorted(Map<String, Integer>, Map<String, List<String>>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt> +<dd> </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,%20java.lang.Throwable)">ApiException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt> +<dd> </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/Consumer.html#assign(java.util.Collection)">assign(Collection<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#assign(java.util.Collection)">assign(Collection<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">Manually assign a list of partition to this consumer.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#assign(java.util.Collection)">assign(Collection<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><span class="strong"><a href="./org/apache/kafka/clients/consumer/RangeAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map<String, Integer>, Map<String, List<String>>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RangeAssignor.html" title="class in org.apache.kafka.clients.consumer">RangeAssignor</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map<String, Integer>, Map<String, List<String>>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#assignment()">assignment()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#assignment()">assignment()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Get the set of partitions currently assigned to this consumer.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#assignment()">assignment()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.Range.html#atLeast(java.lang.Number)">atLeast(Number)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.Range.html" title="class in org.apache.kafka.common.config">ConfigDef.Range</a></dt> +<dd> +<div class="block">A numeric range that checks only the lower bound</div> +</dd> +<dt><a href="./org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">AuthenticationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthenticationException.html#AuthenticationException(java.lang.String)">AuthenticationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors">AuthenticationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthenticationException.html#AuthenticationException(java.lang.String,%20java.lang.Throwable)">AuthenticationException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors">AuthenticationException</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">AuthorizationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthorizationException.html#AuthorizationException(java.lang.String)">AuthorizationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthorizationException.html#AuthorizationException(java.lang.String,%20java.lang.Throwable)">AuthorizationException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></dt> +<dd> </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> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_OFFSET_RESET_DOC">AUTO_OFFSET_RESET_DOC</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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#availablePartitionsForTopic(java.lang.String)">availablePartitionsForTopic(String)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt> +<dd> +<div class="block">Get the list of available partitions for this topic</div> +</dd> +</dl> +<a name="_B_"> <!-- --> </a> <h2 class="title">B</h2> <dl> -<dt><span class="strong"><a href="./kafka/javaapi/consumer/ConsumerRebalanceListener.html#beforeReleasingPartitions(java.util.Map)">beforeReleasingPartitions(Map<String, Set<Integer>>)</a></span> - Method in interface kafka.javaapi.consumer.<a href="./kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer">ConsumerRebalanceListener</a></dt> +<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/common/config/ConfigDef.Range.html#between(java.lang.Number,%20java.lang.Number)">between(Number, Number)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.Range.html" title="class in org.apache.kafka.common.config">ConfigDef.Range</a></dt> +<dd> +<div class="block">A numeric range that checks both the upper and lower bound</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"><span class="strong">Deprecated.</span> +<div class="block"><i>This config will be removed in a future release. Also, the <a href="./org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_FETCH_TIMEOUT_CONFIG"><code>ProducerConfig.METADATA_FETCH_TIMEOUT_CONFIG</code></a> is no longer honored when this property is set to true.</i></div> +</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)">bootstrap(List<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><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors"><span class="strong">BrokerNotAvailableException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html#BrokerNotAvailableException(java.lang.String)">BrokerNotAvailableException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors">BrokerNotAvailableException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html#BrokerNotAvailableException(java.lang.String,%20java.lang.Throwable)">BrokerNotAvailableException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors">BrokerNotAvailableException</a></dt> +<dd> </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><span class="strong"><a href="./org/apache/kafka/common/serialization/Serdes.html#ByteArray()">ByteArray()</a></span> - Static method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serdes.html" title="class in org.apache.kafka.common.serialization">Serdes</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> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serdes.html#ByteBuffer()">ByteBuffer()</a></span> - Static method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serdes.html" title="class in org.apache.kafka.common.serialization">Serdes</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/serialization/ByteBufferDeserializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">ByteBufferDeserializer</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/ByteBufferDeserializer.html#ByteBufferDeserializer()">ByteBufferDeserializer()</a></span> - Constructor for class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteBufferDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteBufferDeserializer</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/serialization/ByteBufferSerializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">ByteBufferSerializer</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/ByteBufferSerializer.html#ByteBufferSerializer()">ByteBufferSerializer()</a></span> - Constructor for class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteBufferSerializer.html" title="class in org.apache.kafka.common.serialization">ByteBufferSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serdes.html#Bytes()">Bytes()</a></span> - Static method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serdes.html" title="class in org.apache.kafka.common.serialization">Serdes</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/serialization/BytesDeserializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">BytesDeserializer</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/BytesDeserializer.html#BytesDeserializer()">BytesDeserializer()</a></span> - Constructor for class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/BytesDeserializer.html" title="class in org.apache.kafka.common.serialization">BytesDeserializer</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/serialization/BytesSerializer.html" title="class in org.apache.kafka.common.serialization"><span class="strong">BytesSerializer</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/BytesSerializer.html#BytesSerializer()">BytesSerializer()</a></span> - Constructor for class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/BytesSerializer.html" title="class in org.apache.kafka.common.serialization">BytesSerializer</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/consumer/ConsumerRecord.html#checksum()">checksum()</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 checksum (CRC32) of the record.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/RecordMetadata.html#checksum()">checksum()</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 checksum (CRC32) of the record.</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/ConsumerInterceptor.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerInterceptor.html" title="interface in org.apache.kafka.clients.consumer">ConsumerInterceptor</a></dt> +<dd> +<div class="block">This is called when interceptor is closed</div> +</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> +<div class="block">Close the consumer, waiting indefinitely for any needed cleanup.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#close()">close()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#close()">close()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer">KafkaProducer</a></dt> +<dd> +<div class="block">Close this producer.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#close(long,%20java.util.concurrent.TimeUnit)">close(long, TimeUnit)</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer">KafkaProducer</a></dt> +<dd> +<div class="block">This method waits up to <code>timeout</code> for the producer to complete the sending of all incomplete requests.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#close()">close()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#close(long,%20java.util.concurrent.TimeUnit)">close(long, TimeUnit)</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Partitioner.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Partitioner.html" title="interface in org.apache.kafka.clients.producer">Partitioner</a></dt> +<dd> +<div class="block">This is called when partitioner is closed.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a></dt> +<dd> +<div class="block">Close this producer</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#close(long,%20java.util.concurrent.TimeUnit)">close(long, TimeUnit)</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a></dt> +<dd> +<div class="block">Tries to close the producer cleanly within the specified timeout.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerInterceptor.html#close()">close()</a></span> - Method in interface org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerInterceptor.html" title="interface in org.apache.kafka.clients.producer">ProducerInterceptor</a></dt> +<dd> +<div class="block">This is called when interceptor is closed</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/ByteBufferDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteBufferDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteBufferDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteBufferSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteBufferSerializer.html" title="class in org.apache.kafka.common.serialization">ByteBufferSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/BytesDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/BytesDeserializer.html" title="class in org.apache.kafka.common.serialization">BytesDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/BytesSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/BytesSerializer.html" title="class in org.apache.kafka.common.serialization">BytesSerializer</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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/DoubleDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/DoubleDeserializer.html" title="class in org.apache.kafka.common.serialization">DoubleDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/DoubleSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/DoubleSerializer.html" title="class in org.apache.kafka.common.serialization">DoubleSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization">IntegerSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongDeserializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization">LongDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongSerializer.html" title="class in org.apache.kafka.common.serialization">LongSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serde.html#close()">close()</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a></dt> +<dd> +<div class="block">Close this serde class, which will close the underlying serializer and 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><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#closed()">closed()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </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,%20java.util.Collection,%20java.util.Set)">Cluster(Collection<Node>, Collection<PartitionInfo>, Set<String>)</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><a href="./org/apache/kafka/common/errors/ClusterAuthorizationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">ClusterAuthorizationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ClusterAuthorizationException.html#ClusterAuthorizationException(java.lang.String)">ClusterAuthorizationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ClusterAuthorizationException.html" title="class in org.apache.kafka.common.errors">ClusterAuthorizationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ClusterAuthorizationException.html#ClusterAuthorizationException(java.lang.String,%20java.lang.Throwable)">ClusterAuthorizationException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ClusterAuthorizationException.html" title="class in org.apache.kafka.common.errors">ClusterAuthorizationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync()">commitAsync()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync()">commitAsync()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Commit offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for all the subscribed list of topics and partition.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Commit offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for the subscribed list of topics and partitions.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Commit the specified offsets for the specified list of topics and partitions to Kafka.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync()">commitAsync()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/clients/consumer/CommitFailedException.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">CommitFailedException</span></a> - Exception in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt> +<dd> +<div class="block">This exception is raised when an offset commit with <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync()"><code>KafkaConsumer.commitSync()</code></a> fails + with an unrecoverable error.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/CommitFailedException.html#CommitFailedException(java.lang.String)">CommitFailedException(String)</a></span> - Constructor for exception org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/CommitFailedException.html" title="class in org.apache.kafka.clients.consumer">CommitFailedException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitSync()">commitSync()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitSync(java.util.Map)">commitSync(Map<TopicPartition, OffsetAndMetadata>)</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#commitSync()">commitSync()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Commit offsets returned on the last <a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll()</code></a> for all the subscribed list of topics and partitions.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)">commitSync(Map<TopicPartition, OffsetAndMetadata>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Commit the specified offsets for the specified list of topics and partitions.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#commitSync(java.util.Map)">commitSync(Map<TopicPartition, OffsetAndMetadata>)</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#commitSync()">commitSync()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </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">Get the last committed offset for the given partition (whether the commit happened by this process or + another).</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#committed(org.apache.kafka.common.TopicPartition)">committed(TopicPartition)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </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/config/Config.html" title="class in org.apache.kafka.common.config"><span class="strong">Config</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/Config.html#Config(java.util.List)">Config(List<ConfigValue>)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/Config.html" title="class in org.apache.kafka.common.config">Config</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.html" title="class in org.apache.kafka.common.config"><span class="strong">ConfigDef</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">This class is used for specifying the set of expected configurations.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.html#ConfigDef()">ConfigDef()</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.html" title="class in org.apache.kafka.common.config">ConfigDef</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html" title="class in org.apache.kafka.common.config"><span class="strong">ConfigDef.ConfigKey</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html#ConfigDef.ConfigKey(java.lang.String,%20org.apache.kafka.common.config.ConfigDef.Type,%20java.lang.Object,%20org.apache.kafka.common.config.ConfigDef.Validator,%20org.apache.kafka.common.config.ConfigDef.Importance,%20java.lang.String,%20java.lang.String,%20int,%20org.apache.kafka.common.config.ConfigDef.Width,%20java.lang.String,%20java.util.List,%20org.apache.kafka.common.config.ConfigDef.Recommender)">ConfigDef.ConfigKey(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html" title="class in org.apache.kafka.common.config">ConfigDef.ConfigKey</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.Importance.html" title="enum in org.apache.kafka.common.config"><span class="strong">ConfigDef.Importance</span></a> - Enum in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">The importance level for a configuration</div> +</dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.Range.html" title="class in org.apache.kafka.common.config"><span class="strong">ConfigDef.Range</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">Validation logic for numeric ranges</div> +</dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.Recommender.html" title="interface in org.apache.kafka.common.config"><span class="strong">ConfigDef.Recommender</span></a> - Interface in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">This is used by the <a href="./org/apache/kafka/common/config/ConfigDef.html#validate(java.util.Map)"><code>ConfigDef.validate(Map)</code></a> to get valid values for a configuration given the current + configuration values in order to perform full configuration validation and visibility modification.</div> +</dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.Type.html" title="enum in org.apache.kafka.common.config"><span class="strong">ConfigDef.Type</span></a> - Enum in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">The config types</div> +</dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.Validator.html" title="interface in org.apache.kafka.common.config"><span class="strong">ConfigDef.Validator</span></a> - Interface in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">Validation logic the user may provide to perform single configuration validation.</div> +</dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.ValidString.html" title="class in org.apache.kafka.common.config"><span class="strong">ConfigDef.ValidString</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/config/ConfigDef.Width.html" title="enum in org.apache.kafka.common.config"><span class="strong">ConfigDef.Width</span></a> - Enum in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">The width of a configuration value</div> +</dd> +<dt><a href="./org/apache/kafka/common/config/ConfigException.html" title="class in org.apache.kafka.common.config"><span class="strong">ConfigException</span></a> - Exception in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> +<div class="block">Thrown if the user supplies an invalid configuration</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigException.html#ConfigException(java.lang.String)">ConfigException(String)</a></span> - Constructor for exception org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigException.html" title="class in org.apache.kafka.common.config">ConfigException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigException.html#ConfigException(java.lang.String,%20java.lang.Object)">ConfigException(String, Object)</a></span> - Constructor for exception org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigException.html" title="class in org.apache.kafka.common.config">ConfigException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigException.html#ConfigException(java.lang.String,%20java.lang.Object,%20java.lang.String)">ConfigException(String, Object, String)</a></span> - Constructor for exception org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigException.html" title="class in org.apache.kafka.common.config">ConfigException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.html#configKeys()">configKeys()</a></span> - Method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.html" title="class in org.apache.kafka.common.config">ConfigDef</a></dt> +<dd> +<div class="block">Get the configuration keys</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,%20boolean)">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,%20boolean)">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/ByteBufferDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteBufferDeserializer.html" title="class in org.apache.kafka.common.serialization">ByteBufferDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/ByteBufferSerializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/ByteBufferSerializer.html" title="class in org.apache.kafka.common.serialization">ByteBufferSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/BytesDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/BytesDeserializer.html" title="class in org.apache.kafka.common.serialization">BytesDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/BytesSerializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/BytesSerializer.html" title="class in org.apache.kafka.common.serialization">BytesSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Deserializer.html#configure(java.util.Map,%20boolean)">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/DoubleDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/DoubleDeserializer.html" title="class in org.apache.kafka.common.serialization">DoubleDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/DoubleSerializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/DoubleSerializer.html" title="class in org.apache.kafka.common.serialization">DoubleSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/IntegerSerializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization">IntegerSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongDeserializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization">LongDeserializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/LongSerializer.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/LongSerializer.html" title="class in org.apache.kafka.common.serialization">LongSerializer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serde.html#configure(java.util.Map,%20boolean)">configure(Map<String, ?>, boolean)</a></span> - Method in interface org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization">Serde</a></dt> +<dd> +<div class="block">Configure this class, which will configure the underlying serializer and deserializer.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serializer.html#configure(java.util.Map,%20boolean)">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,%20boolean)">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,%20boolean)">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/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config"><span class="strong">ConfigValue</span></a> - Class in <a href="./org/apache/kafka/common/config/package-summary.html">org.apache.kafka.common.config</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigValue.html#ConfigValue(java.lang.String)">ConfigValue(String)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config">ConfigValue</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigValue.html#ConfigValue(java.lang.String,%20java.lang.Object,%20java.util.List,%20java.util.List)">ConfigValue(String, Object, List<Object>, List<String>)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config">ConfigValue</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/Config.html#configValues()">configValues()</a></span> - Method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/Config.html" title="class in org.apache.kafka.common.config">Config</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG">CONNECTIONS_MAX_IDLE_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt> +<dd> +<div class="block"><code>connections.max.idle.ms</code></div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG">CONNECTIONS_MAX_IDLE_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt> +<dd> +<div class="block"><code>connections.max.idle.ms</code></div> +</dd> +<dt><a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">Consumer</span></a><<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><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/ConsumerInterceptor.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">ConsumerInterceptor</span></a><<a href="./org/apache/kafka/clients/consumer/ConsumerInterceptor.html" title="type parameter in ConsumerInterceptor">K</a>,<a href="./org/apache/kafka/clients/consumer/ConsumerInterceptor.html" title="type parameter in ConsumerInterceptor">V</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 plugin interface that allows you to intercept (and possibly mutate) records received by the consumer.</div> +</dd> +<dt><a href="./org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRebalanceListener</span></a> - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt> +<dd> +<div class="block">A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the + consumer changes.</div> +</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,%20int,%20long,%20K,%20V)">ConsumerRecord(String, int, long, K, V)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecord</a></dt> +<dd> +<div class="block">Creates a record to be received from a specified topic and partition (provided for + compatibility with Kafka 0.9 before the message format supported timestamps and before + serialized metadata were exposed).</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecord.html#ConsumerRecord(java.lang.String,%20int,%20long,%20long,%20org.apache.kafka.common.record.TimestampType,%20long,%20int,%20int,%20K,%20V)">ConsumerRecord(String, int, long, long, TimestampType, long, int, int, 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">Creates a record to be received from a specified topic and partition</div> +</dd> +<dt><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRecords</span></a><<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/ControllerMovedException.html" title="class in org.apache.kafka.common.errors"><span class="strong">ControllerMovedException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ControllerMovedException.html#ControllerMovedException(java.lang.String)">ControllerMovedException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ControllerMovedException.html#ControllerMovedException(java.lang.String,%20java.lang.Throwable)">ControllerMovedException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.html#convertToString(java.lang.Object,%20org.apache.kafka.common.config.ConfigDef.Type)">convertToString(Object, ConfigDef.Type)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.html" title="class in org.apache.kafka.common.config">ConfigDef</a></dt> +<dd> </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 its internal CRC check, this generally indicates network or disk + corruption.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/CorruptRecordException.html#CorruptRecordException()">CorruptRecordException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></dt> +<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,%20java.lang.Throwable)">CorruptRecordException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></dt> +<dd> </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/clients/consumer/ConsumerConfig.html#DEFAULT_EXCLUDE_INTERNAL_TOPICS">DEFAULT_EXCLUDE_INTERNAL_TOPICS</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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_KERBEROS_KINIT_CMD">DEFAULT_KERBEROS_KINIT_CMD</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_KERBEROS_MIN_TIME_BEFORE_RELOGIN">DEFAULT_KERBEROS_MIN_TIME_BEFORE_RELOGIN</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_KERBEROS_TICKET_RENEW_JITTER">DEFAULT_KERBEROS_TICKET_RENEW_JITTER</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_KERBEROS_TICKET_RENEW_WINDOW_FACTOR">DEFAULT_KERBEROS_TICKET_RENEW_WINDOW_FACTOR</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_MAX_PARTITION_FETCH_BYTES">DEFAULT_MAX_PARTITION_FETCH_BYTES</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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_PRINCIPAL_BUILDER_CLASS">DEFAULT_PRINCIPAL_BUILDER_CLASS</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_SASL_ENABLED_MECHANISMS">DEFAULT_SASL_ENABLED_MECHANISMS</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES">DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SaslConfigs.html#DEFAULT_SASL_MECHANISM">DEFAULT_SASL_MECHANISM</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_SSL_ENABLED_PROTOCOLS">DEFAULT_SSL_ENABLED_PROTOCOLS</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_SSL_KEYMANGER_ALGORITHM">DEFAULT_SSL_KEYMANGER_ALGORITHM</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_SSL_KEYSTORE_TYPE">DEFAULT_SSL_KEYSTORE_TYPE</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_SSL_PROTOCOL">DEFAULT_SSL_PROTOCOL</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_SSL_TRUSTMANAGER_ALGORITHM">DEFAULT_SSL_TRUSTMANAGER_ALGORITHM</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#DEFAULT_SSL_TRUSTSTORE_TYPE">DEFAULT_SSL_TRUSTSTORE_TYPE</a></span> - Static variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html#defaultValue">defaultValue</a></span> - Variable in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html" title="class in org.apache.kafka.common.config">ConfigDef.ConfigKey</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.html#define(java.lang.String,%20org.apache.kafka.common.config.ConfigDef.Type,%20java.lang.Object,%20org.apache.kafka.common.config.ConfigDef.Validator,%20org.apache.kafka.common.config.ConfigDef.Importance,%20java.lang.String,%20java.lang.String,%20int,%20org.apache.kafka.common.config.ConfigDef.Width,%20java.lang.String,%20java.util.List,%20org.apache.kafka.common.config.ConfigDef.Recommender)">define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender)</a></span> - Method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.html" title="class in org.apache.kafka.common.config">ConfigDef</a></dt> +<dd> +<div class="block">Define a new configuration</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.html#define(java.lang.String,%20org.apache.kafka.common.config.ConfigDef.Type,%20java.lang.Object,%20org.apache.kafka.common.config.ConfigDef.Validator,%20org.apache.kafka.common.config.Con
<TRUNCATED>
