You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2016/10/04 21:28:25 UTC
[47/51] [partial] kafka-site git commit: Add 0.10.1 javadocs
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2d621da3/0101/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/0101/javadoc/index-all.html b/0101/javadoc/index-all.html
new file mode 100644
index 0000000..9b5dfa0
--- /dev/null
+++ b/0101/javadoc/index-all.html
@@ -0,0 +1,5515 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<!-- NewPage -->
+<html lang="en">
+<head>
+<!-- Generated by javadoc (version 1.7.0_79) on Tue Oct 04 12:37:09 PDT 2016 -->
+<title>Index (kafka 0.10.1.0 API)</title>
+<meta name="date" content="2016-10-04">
+<link rel="stylesheet" type="text/css" href="./stylesheet.css" title="Style">
+</head>
+<body>
+<script type="text/javascript"><!--
+ if (location.href.indexOf('is-external=true') == -1) {
+ parent.document.title="Index (kafka 0.10.1.0 API)";
+ }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar_top">
+<!-- -->
+</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow">
+<!-- -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="./overview-summary.html">Overview</a></li>
+<li>Package</li>
+<li>Class</li>
+<li><a href="./overview-tree.html">Tree</a></li>
+<li><a href="./deprecated-list.html">Deprecated</a></li>
+<li class="navBarCell1Rev">Index</li>
+<li><a href="./help-doc.html">Help</a></li>
+</ul>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="./index.html?index-all.html" target="_top">Frames</a></li>
+<li><a href="index-all.html" target="_top">No Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="./allclasses-noframe.html">All Classes</a></li>
+</ul>
+<div>
+<script type="text/javascript"><!--
+ allClassesLink = document.getElementById("allclasses_navbar_top");
+ if(window==top) {
+ allClassesLink.style.display = "block";
+ }
+ else {
+ allClassesLink.style.display = "none";
+ }
+ //-->
+</script>
+</div>
+<a name="skip-navbar_top">
+<!-- -->
+</a></div>
+<!-- ========= END OF TOP NAVBAR ========= -->
+<div class="contentContainer"><a href="#_A_">A</a> <a href="#_B_">B</a> <a href="#_C_">C</a> <a href="#_D_">D</a> <a href="#_E_">E</a> <a href="#_F_">F</a> <a href="#_G_">G</a> <a href="#_H_">H</a> <a href="#_I_">I</a> <a href="#_J_">J</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="#_Q_">Q</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 href="#_Z_">Z</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><a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor"><span class="strong">AbstractProcessor</span></a><<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="type parameter in AbstractProcessor">K</a>,<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="type parameter in AbstractProcessor">V</a>> - Class in <a href="./org/apache/kafka/streams/processor/package-summary.html">org.apache.kafka.streams.processor</a></dt>
+<dd>
+<div class="block">An abstract implementation of <a href="./org/apache/kafka/streams/processor/Processor.html" title="interface in org.apache.kafka.streams.processor"><code>Processor</code></a> that manages the <a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor"><code>ProcessorContext</code></a> instance and provides default no-op
+ implementations of <a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#punctuate(long)"><code>AbstractProcessor.punctuate(long)</code></a> and <a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#close()"><code>AbstractProcessor.close()</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#AbstractProcessor()">AbstractProcessor()</a></span> - Constructor for class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor">AbstractProcessor</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/QueryableStoreType.html#accepts(org.apache.kafka.streams.processor.StateStore)">accepts(StateStore)</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/QueryableStoreType.html" title="interface in org.apache.kafka.streams.state">QueryableStoreType</a></dt>
+<dd>
+<div class="block">Called when searching for <a href="./org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a>s to see if they
+ match the type expected by implementors of this interface</div>
+</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/streams/processor/TopologyBuilder.html#addInternalTopic(java.lang.String)">addInternalTopic(String)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Adds an internal topic</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsMetrics.html#addLatencySensor(java.lang.String,%20java.lang.String,%20java.lang.String,%20java.lang.String...)">addLatencySensor(String, String, String, String...)</a></span> - Method in interface org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsMetrics.html" title="interface in org.apache.kafka.streams">StreamsMetrics</a></dt>
+<dd>
+<div class="block">Add the latency sensor.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addProcessor(java.lang.String,%20org.apache.kafka.streams.processor.ProcessorSupplier,%20java.lang.String...)">addProcessor(String, ProcessorSupplier, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new processor node that receives and processes records output by one or more parent source or processor node.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#addRecord(org.apache.kafka.clients.consumer.ConsumerRecord)">addRecord(ConsumerRecord<K, V>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
+<dd> </dd>
+<dt><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/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20java.lang.String...)">addSink(String, String, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String...)">addSink(String, String, StreamPartitioner, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic, using
+ the supplied partitioner.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer,%20java.lang.String...)">addSink(String, String, Serializer, Serializer, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String...)">addSink(String, String, Serializer<K>, Serializer<V>, StreamPartitioner<K, V>, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSource(java.lang.String,%20java.lang.String...)">addSource(String, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new source that consumes the named topics and forward the records to child processor and/or sink nodes.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSource(java.lang.String,%20java.util.regex.Pattern)">addSource(String, Pattern)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new source that consumes from topics matching the given pattern
+ and forward the records to child processor and/or sink nodes.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSource(java.lang.String,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.lang.String...)">addSource(String, Deserializer, Deserializer, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new source that consumes the named topics and forwards the records to child processor and/or sink nodes.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSource(java.lang.String,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.util.regex.Pattern)">addSource(String, Deserializer, Deserializer, Pattern)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Add a new source that consumes from topics matching the given pattern
+ and forwards the records to child processor and/or sink nodes.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addStateStore(org.apache.kafka.streams.processor.StateStoreSupplier,%20java.lang.String...)">addStateStore(StateStoreSupplier, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Adds a state store</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/TimeWindows.html#advance">advance</a></span> - Variable in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/TimeWindows.html" title="class in org.apache.kafka.streams.kstream">TimeWindows</a></dt>
+<dd>
+<div class="block">The size of the window's advance interval, i.e.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/TimeWindows.html#advanceBy(long)">advanceBy(long)</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/TimeWindows.html" title="class in org.apache.kafka.streams.kstream">TimeWindows</a></dt>
+<dd>
+<div class="block">Returns a window definition with the original size, but advance ("hop") the window by the given
+ interval, which specifies by how much a window moves forward relative to the previous one.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/JoinWindows.html#after">after</a></span> - Variable in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/JoinWindows.html" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></dt>
+<dd>
+<div class="block">Maximum time difference for tuples that are after the join tuple.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/JoinWindows.html#after(long)">after(long)</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/JoinWindows.html" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></dt>
+<dd>
+<div class="block">Specifies that records of the same key are joinable if their timestamps are within
+ the join window interval, and if the timestamp of a record from the secondary stream
+ is later than or equal to the timestamp of a record from the first stream.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KGroupedStream.html#aggregate(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">aggregate(Initializer<T>, Aggregator<K, V, T>, Serde<T>, String)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KGroupedStream.html" title="interface in org.apache.kafka.streams.kstream">KGroupedStream</a></dt>
+<dd>
+<div class="block">Aggregate values of this stream by key into a new instance of a <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KGroupedStream.html#aggregate(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Windows,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">aggregate(Initializer<T>, Aggregator<K, V, T>, Windows<W>, Serde<T>, String)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KGroupedStream.html" title="interface in org.apache.kafka.streams.kstream">KGroupedStream</a></dt>
+<dd>
+<div class="block">Aggregate values of this stream by key on a window basis into a new instance of windowed <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KGroupedTable.html#aggregate(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">aggregate(Initializer<T>, Aggregator<K, V, T>, Aggregator<K, V, T>, Serde<T>, String)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a></dt>
+<dd>
+<div class="block">Aggregate updating values of this stream by the selected key into a new instance of <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KGroupedTable.html#aggregate(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Aggregator,%20java.lang.String)">aggregate(Initializer<T>, Aggregator<K, V, T>, Aggregator<K, V, T>, String)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream">KGroupedTable</a></dt>
+<dd>
+<div class="block">Aggregate updating values of this stream by the selected key into a new instance of <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>
+ using default serializers and deserializers.</div>
+</dd>
+<dt><a href="./org/apache/kafka/streams/kstream/Aggregator.html" title="interface in org.apache.kafka.streams.kstream"><span class="strong">Aggregator</span></a><<a href="./org/apache/kafka/streams/kstream/Aggregator.html" title="type parameter in Aggregator">K</a>,<a href="./org/apache/kafka/streams/kstream/Aggregator.html" title="type parameter in Aggregator">V</a>,<a href="./org/apache/kafka/streams/kstream/Aggregator.html" title="type parameter in Aggregator">T</a>> - Interface in <a href="./org/apache/kafka/streams/kstream/package-summary.html">org.apache.kafka.streams.kstream</a></dt>
+<dd>
+<div class="block">The <a href="./org/apache/kafka/streams/kstream/Aggregator.html" title="interface in org.apache.kafka.streams.kstream"><code>Aggregator</code></a> interface for aggregating values of the given key.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#all()">all()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html" title="interface in org.apache.kafka.streams.state">ReadOnlyKeyValueStore</a></dt>
+<dd>
+<div class="block">Return an iterator over all keys in this store.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/KafkaStreams.html#allMetadata()">allMetadata()</a></span> - Method in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams">KafkaStreams</a></dt>
+<dd>
+<div class="block">Find all of the instances of <a href="./org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state"><code>StreamsMetadata</code></a> in the <a href="./org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams"><code>KafkaStreams</code></a> application that this instance belongs to
+
+ Note: this is a point in time view and it may change due to partition reassignment.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/KafkaStreams.html#allMetadataForStore(java.lang.String)">allMetadataForStore(String)</a></span> - Method in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams">KafkaStreams</a></dt>
+<dd>
+<div class="block">Find instances of <a href="./org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state"><code>StreamsMetadata</code></a> that contains the given storeName
+
+ Note: this is a point in time view and it may change due to partition reassignment.</div>
+</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/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors"><span class="strong">AlreadyExistsException</span></a> - Exception in <a href="./org/apache/kafka/connect/errors/package-summary.html">org.apache.kafka.connect.errors</a></dt>
+<dd>
+<div class="block">Indicates the operation tried to create an entity that already exists.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html#AlreadyExistsException(java.lang.String)">AlreadyExistsException(String)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html#AlreadyExistsException(java.lang.String,%20java.lang.Throwable)">AlreadyExistsException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html#AlreadyExistsException(java.lang.Throwable)">AlreadyExistsException(Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</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/streams/processor/ProcessorContext.html#appConfigs()">appConfigs()</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor">ProcessorContext</a></dt>
+<dd>
+<div class="block">Returns all the application config properties as key/value pairs.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/ProcessorContext.html#appConfigsWithPrefix(java.lang.String)">appConfigsWithPrefix(String)</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor">ProcessorContext</a></dt>
+<dd>
+<div class="block">Returns all the application config properties with the given key prefix, as key/value pairs
+ stripping the prefix.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG">APPLICATION_ID_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd>
+<div class="block"><code>application.id</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_DOC">APPLICATION_ID_DOC</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_SERVER_CONFIG">APPLICATION_SERVER_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd>
+<div class="block"><code>user.endpoint</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_SERVER_DOC">APPLICATION_SERVER_DOC</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/ProcessorContext.html#applicationId()">applicationId()</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor">ProcessorContext</a></dt>
+<dd>
+<div class="block">Returns the application id</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Aggregator.html#apply(K,%20V,%20T)">apply(K, V, T)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Aggregator.html" title="interface in org.apache.kafka.streams.kstream">Aggregator</a></dt>
+<dd>
+<div class="block">Compute a new aggregate from the key and value of a record and the current aggregate of the same key.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/ForeachAction.html#apply(K,%20V)">apply(K, V)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/ForeachAction.html" title="interface in org.apache.kafka.streams.kstream">ForeachAction</a></dt>
+<dd>
+<div class="block">Perform an action for each record of a stream.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Initializer.html#apply()">apply()</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Initializer.html" title="interface in org.apache.kafka.streams.kstream">Initializer</a></dt>
+<dd>
+<div class="block">Return the initial value for an aggregation.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KeyValueMapper.html#apply(K,%20V)">apply(K, V)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream">KeyValueMapper</a></dt>
+<dd>
+<div class="block">Map a record with the given key and value to a new value.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Reducer.html#apply(V,%20V)">apply(V, V)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Reducer.html" title="interface in org.apache.kafka.streams.kstream">Reducer</a></dt>
+<dd>
+<div class="block">Aggregate the two given values into a single one.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/ValueJoiner.html#apply(V1,%20V2)">apply(V1, V2)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream">ValueJoiner</a></dt>
+<dd>
+<div class="block">Return a joined value consisting of <code>value1</code> and <code>value2</code>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/ValueMapper.html#apply(V1)">apply(V1)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/ValueMapper.html" title="interface in org.apache.kafka.streams.kstream">ValueMapper</a></dt>
+<dd>
+<div class="block">Map the given value to a new value.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html#approximateNumEntries()">approximateNumEntries()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html" title="interface in org.apache.kafka.streams.state">ReadOnlyKeyValueStore</a></dt>
+<dd>
+<div class="block">Return an approximate count of key-value mappings in this store.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#array(org.apache.kafka.connect.data.Schema)">array(Schema)</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/SchemaBuilder.html" title="class in org.apache.kafka.connect.data">SchemaBuilder</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/connect/sink/SinkTaskContext.html#assignment()">assignment()</a></span> - Method in interface org.apache.kafka.connect.sink.<a href="./org/apache/kafka/connect/sink/SinkTaskContext.html" title="interface in org.apache.kafka.connect.sink">SinkTaskContext</a></dt>
+<dd>
+<div class="block">Get the current set of assigned TopicPartitions for this task.</div>
+</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="./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/streams/kstream/JoinWindows.html#before">before</a></span> - Variable in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/JoinWindows.html" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></dt>
+<dd>
+<div class="block">Maximum time difference for tuples that are before the join tuple.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/JoinWindows.html#before(long)">before(long)</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/JoinWindows.html" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></dt>
+<dd>
+<div class="block">Specifies that records of the same key are joinable if their timestamps are within
+ the join window interval, and if the timestamp of a record from the secondary stream is
+ earlier than or equal to the timestamp of a record from the first stream.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#beginningOffsets(java.util.Collection)">beginningOffsets(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#beginningOffsets(java.util.Collection)">beginningOffsets(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">Get the first offset for the given partitions.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#beginningOffsets(java.util.Collection)">beginningOffsets(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/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. Please use <a href="./org/apache/kafka/clients/producer/ProducerConfig.html#MAX_BLOCK_MS_CONFIG"><code>ProducerConfig.MAX_BLOCK_MS_CONFIG</code></a>.</i></div>
+</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#bool()">bool()</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/SchemaBuilder.html" title="class in org.apache.kafka.connect.data">SchemaBuilder</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Schema.html#BOOLEAN_SCHEMA">BOOLEAN_SCHEMA</a></span> - Static variable in interface org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)">bootstrap(List<InetSocketAddress>)</a></span> - Static method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt>
+<dd>
+<div class="block">Create a "bootstrap" cluster using the given list of host/ports</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#BOOTSTRAP_SERVERS_CONFIG">BOOTSTRAP_SERVERS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt>
+<dd>
+<div class="block"><code>bootstrap.servers</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#BOOTSTRAP_SERVERS_CONFIG">BOOTSTRAP_SERVERS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
+<dd>
+<div class="block"><code>bootstrap.servers</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#BOOTSTRAP_SERVERS_CONFIG">BOOTSTRAP_SERVERS_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd>
+<div class="block"><code>bootstrap.servers</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KStream.html#branch(org.apache.kafka.streams.kstream.Predicate...)">branch(Predicate<K, V>...)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream">KStream</a></dt>
+<dd>
+<div class="block">Creates an array of <a href="./org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><code>KStream</code></a> from this stream by branching the elements in the original stream based on the supplied predicates.</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><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#BUFFERED_RECORDS_PER_PARTITION_CONFIG">BUFFERED_RECORDS_PER_PARTITION_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd>
+<div class="block"><code>buffered.records.per.partition</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/connect/data/SchemaBuilder.html#build()">build()</a></span> - Method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/SchemaBuilder.html" title="class in org.apache.kafka.connect.data">SchemaBuilder</a></dt>
+<dd>
+<div class="block">Build the Schema using the current settings</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#build(java.lang.Integer)">build(Integer)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt>
+<dd>
+<div class="block">Build the topology for the specified topic group.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html#build()">build()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html" title="interface in org.apache.kafka.streams.state">Stores.InMemoryKeyValueFactory</a></dt>
+<dd>
+<div class="block">Return the instance of StateStoreSupplier of new key-value store.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html#build()">build()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html" title="interface in org.apache.kafka.streams.state">Stores.PersistentKeyValueFactory</a></dt>
+<dd>
+<div class="block">Return the instance of StateStoreSupplier of new key-value store.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Date.html#builder()">builder()</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/Date.html" title="class in org.apache.kafka.connect.data">Date</a></dt>
+<dd>
+<div class="block">Returns a SchemaBuilder for a Date.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Decimal.html#builder(int)">builder(int)</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/Decimal.html" title="class in org.apache.kafka.connect.data">Decimal</a></dt>
+<dd>
+<div class="block">Returns a SchemaBuilder for a Decimal with the given scale factor.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Time.html#builder()">builder()</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/Time.html" title="class in org.apache.kafka.connect.data">Time</a></dt>
+<dd>
+<div class="block">Returns a SchemaBuilder for a Time.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Timestamp.html#builder()">builder()</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/Timestamp.html" title="class in org.apache.kafka.connect.data">Timestamp</a></dt>
+<dd>
+<div class="block">Returns a SchemaBuilder for a Timestamp.</div>
+</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><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#bytes()">bytes()</a></span> - Static method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/SchemaBuilder.html" title="class in org.apache.kafka.connect.data">SchemaBuilder</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Schema.html#BYTES_SCHEMA">BYTES_SCHEMA</a></span> - Static variable in interface org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</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><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#CACHE_MAX_BYTES_BUFFERING_CONFIG">CACHE_MAX_BYTES_BUFFERING_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd>
+<div class="block"><code>cache.max.bytes.buffering</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#CACHE_MAX_BYTES_BUFFERING_DOC">CACHE_MAX_BYTES_BUFFERING_DOC</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd> </dd>
+<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/streams/KafkaStreams.html#cleanUp()">cleanUp()</a></span> - Method in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams">KafkaStreams</a></dt>
+<dd>
+<div class="block">Cleans up local state store directory (<code>state.dir</code>), by deleting all data with regard to the application-id.</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/streams/StreamsConfig.html#CLIENT_ID_CONFIG">CLIENT_ID_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</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/Serdes.WrapperSerde.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/Serdes.WrapperSerde.html" title="class in org.apache.kafka.common.serialization">Serdes.WrapperSerde</a></dt>
+<dd> </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/connect/sink/SinkTask.html#close(java.util.Collection)">close(Collection<TopicPartition>)</a></span> - Method in class org.apache.kafka.connect.sink.<a href="./org/apache/kafka/connect/sink/SinkTask.html" title="class in org.apache.kafka.connect.sink">SinkTask</a></dt>
+<dd>
+<div class="block">The SinkTask use this method to close writers for partitions that are no
+ longer assigned to the SinkTask.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/KafkaStreams.html#close()">close()</a></span> - Method in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams">KafkaStreams</a></dt>
+<dd>
+<div class="block">Shutdown this stream instance by signaling all the threads to stop,
+ and then wait for them to join.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Transformer.html#close()">close()</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Transformer.html" title="interface in org.apache.kafka.streams.kstream">Transformer</a></dt>
+<dd>
+<div class="block">Close this processor and clean up any resources.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/ValueTransformer.html#close()">close()</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/ValueTransformer.html" title="interface in org.apache.kafka.streams.kstream">ValueTransformer</a></dt>
+<dd>
+<div class="block">Close this processor and clean up any resources.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#close()">close()</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor">AbstractProcessor</a></dt>
+<dd>
+<div class="block">Close this processor and clean up any resources.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/Processor.html#close()">close()</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/Processor.html" title="interface in org.apache.kafka.streams.processor">Processor</a></dt>
+<dd>
+<div class="block">Close this processor and clean up any resources.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/StateStore.html#close()">close()</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor">StateStore</a></dt>
+<dd>
+<div class="block">Close the storage engine.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/KeyValueIterator.html#close()">close()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/KeyValueIterator.html" title="interface in org.apache.kafka.streams.state">KeyValueIterator</a></dt>
+<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/WindowStoreIterator.html#close()">close()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/WindowStoreIterator.html" title="interface in org.apache.kafka.streams.state">WindowStoreIterator</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"><span class="strong">Deprecated.</span>
+<div class="block"><i>Use the Cluster constructor with 5 parameters</i></div>
+</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#Cluster(java.lang.String,%20java.util.Collection,%20java.util.Collection,%20java.util.Set,%20java.util.Set)">Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, 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 id, 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/common/ClusterResource.html#clusterId()">clusterId()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/ClusterResource.html" title="class in org.apache.kafka.common">ClusterResource</a></dt>
+<dd>
+<div class="block">Return the cluster id.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#clusterResource()">clusterResource()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt>
+<dd> </dd>
+<dt><a href="./org/apache/kafka/common/ClusterResource.html" title="class in org.apache.kafka.common"><span class="strong">ClusterResource</span></a> - Class in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
+<dd>
+<div class="block">The <code>ClusterResource</code> class encapsulates metadata for a Kafka cluster.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/ClusterResource.html#ClusterResource(java.lang.String)">ClusterResource(String)</a></span> - Constructor for class org.apache.kafka.common.<a href="./org/apache/kafka/common/ClusterResource.html" title="class in org.apache.kafka.common">ClusterResource</a></dt>
+<dd>
+<div class="block">Create <a href="./org/apache/kafka/common/ClusterResource.html" title="class in org.apache.kafka.common"><code>ClusterResource</code></a> with a cluster id.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/ClusterResourceListener.html" title="interface in org.apache.kafka.common"><span class="strong">ClusterResourceListener</span></a> - Interface in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
+<dd>
+<div class="block">A callback interface that users can implement when they wish to get notified about changes in the Cluster metadata.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/source/SourceTask.html#commit()">commit()</a></span> - Method in class org.apache.kafka.connect.source.<a href="./org/apache/kafka/connect/source/SourceTask.html" title="class in org.apache.kafka.connect.source">SourceTask</a></dt>
+<dd>
+<div class="block">
+ Commit the offsets, up to the offsets that have been returned by <a href="./org/apache/kafka/connect/source/SourceTask.html#poll()"><code>SourceTask.poll()</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/ProcessorContext.html#commit()">commit()</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor">ProcessorContext</a></dt>
+<dd>
+<div class="block">Requests a commit</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#COMMIT_INTERVAL_MS_CONFIG">COMMIT_INTERVAL_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt>
+<dd>
+<div class="block"><code>commit.interval.ms</code></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync()">commitAsync()</a></span> - Method in interface
<TRUNCATED>