kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject [48/51] [partial] kafka-site git commit: Update javadoc for 0.10 to include connect and streams
Date Thu, 19 May 2016 00:02:38 GMT
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/0100/javadoc/index-all.html b/0100/javadoc/index-all.html
index 71b5afb..3aa4dce 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 Tue May 17 21:36:38 PDT 2016 -->
-<title>Index (clients 0.10.0.0 API)</title>
-<meta name="date" content="2016-05-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:06 BST 2016 -->
+<title>Index (kafka 0.10.0.0 API)</title>
+<meta name="date" content="2016-05-19">
 <link rel="stylesheet" type="text/css" href="./stylesheet.css" title="Style">
 </head>
 <body>
 <script type="text/javascript"><!--
     if (location.href.indexOf('is-external=true') == -1) {
-        parent.document.title="Index (clients 0.10.0.0 API)";
+        parent.document.title="Index (kafka 0.10.0.0 API)";
     }
 //-->
 </script>
@@ -61,7 +61,7 @@
 <!--   -->
 </a></div>
 <!-- ========= END OF TOP NAVBAR ========= -->
-<div class="contentContainer"><a href="#_A_">A</a>&nbsp;<a href="#_B_">B</a>&nbsp;<a href="#_C_">C</a>&nbsp;<a href="#_D_">D</a>&nbsp;<a href="#_E_">E</a>&nbsp;<a href="#_F_">F</a>&nbsp;<a href="#_G_">G</a>&nbsp;<a href="#_H_">H</a>&nbsp;<a href="#_I_">I</a>&nbsp;<a href="#_K_">K</a>&nbsp;<a href="#_L_">L</a>&nbsp;<a href="#_M_">M</a>&nbsp;<a href="#_N_">N</a>&nbsp;<a href="#_O_">O</a>&nbsp;<a href="#_P_">P</a>&nbsp;<a href="#_R_">R</a>&nbsp;<a href="#_S_">S</a>&nbsp;<a href="#_T_">T</a>&nbsp;<a href="#_U_">U</a>&nbsp;<a href="#_V_">V</a>&nbsp;<a href="#_W_">W</a>&nbsp;<a name="_A_">
+<div class="contentContainer"><a href="#_A_">A</a>&nbsp;<a href="#_B_">B</a>&nbsp;<a href="#_C_">C</a>&nbsp;<a href="#_D_">D</a>&nbsp;<a href="#_E_">E</a>&nbsp;<a href="#_F_">F</a>&nbsp;<a href="#_G_">G</a>&nbsp;<a href="#_H_">H</a>&nbsp;<a href="#_I_">I</a>&nbsp;<a href="#_J_">J</a>&nbsp;<a href="#_K_">K</a>&nbsp;<a href="#_L_">L</a>&nbsp;<a href="#_M_">M</a>&nbsp;<a href="#_N_">N</a>&nbsp;<a href="#_O_">O</a>&nbsp;<a href="#_P_">P</a>&nbsp;<a href="#_R_">R</a>&nbsp;<a href="#_S_">S</a>&nbsp;<a href="#_T_">T</a>&nbsp;<a href="#_U_">U</a>&nbsp;<a href="#_V_">V</a>&nbsp;<a href="#_W_">W</a>&nbsp;<a href="#_Z_">Z</a>&nbsp;<a name="_A_">
 <!--   -->
 </a>
 <h2 class="title">A</h2>
@@ -76,6 +76,13 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig(java.util.Map)">AbstractConfig(Map&lt;String, Object&gt;)</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>&nbsp;</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>&lt;<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>&gt; - 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>&nbsp;</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>
@@ -90,14 +97,121 @@
 <dd>&nbsp;</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>&nbsp;</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>&nbsp;</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&lt;K, V&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig(java.util.Map,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Map&lt;String, Object&gt;, Serializer&lt;?&gt;, Serializer&lt;?&gt;)</a></span> - Static method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Properties, Serializer&lt;?&gt;, Serializer&lt;?&gt;)</a></span> - Static method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/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&lt;K&gt;, Serializer&lt;V&gt;, StreamPartitioner&lt;K, V&gt;, 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 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.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#addStateStore(org.apache.kafka.streams.processor.StateStoreSupplier,%20boolean,%20java.lang.String...)">addStateStore(StateStoreSupplier, boolean, 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/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/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&lt;T&gt;, Aggregator&lt;K, V, T&gt;, Aggregator&lt;K, V, T&gt;, Serde&lt;T&gt;, 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&lt;T&gt;, Aggregator&lt;K, V, T&gt;, Aggregator&lt;K, V, T&gt;, 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><span class="strong"><a href="./org/apache/kafka/streams/kstream/KStream.html#aggregateByKey(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Windows,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde)">aggregateByKey(Initializer&lt;T&gt;, Aggregator&lt;K, V, T&gt;, Windows&lt;W&gt;, Serde&lt;K&gt;, Serde&lt;T&gt;)</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">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/KStream.html#aggregateByKey(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Windows)">aggregateByKey(Initializer&lt;T&gt;, Aggregator&lt;K, V, T&gt;, Windows&lt;W&gt;)</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">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>
+ with default serializers and deserializers.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KStream.html#aggregateByKey(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">aggregateByKey(Initializer&lt;T&gt;, Aggregator&lt;K, V, T&gt;, Serde&lt;K&gt;, Serde&lt;T&gt;, String)</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">Aggregate values of this stream by key into a new instance of ever-updating <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/KStream.html#aggregateByKey(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20java.lang.String)">aggregateByKey(Initializer&lt;T&gt;, Aggregator&lt;K, V, T&gt;, String)</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">Aggregate values of this stream by key into a new instance of ever-updating <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>
+ with 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>&lt;<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>&gt; - 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/KeyValueStore.html#all()">all()</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state">KeyValueStore</a></dt>
+<dd>
+<div class="block">Return an iterator over all keys in the database.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html#allPartitionsSorted(java.util.Map,%20java.util.Map)">allPartitionsSorted(Map&lt;String, Integer&gt;, Map&lt;String, List&lt;String&gt;&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt>
 <dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/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>&nbsp;</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>&nbsp;</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>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors"><span class="strong">ApiException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
 <dd>
 <div class="block">Any API exception that is part of the public protocol and should be a subclass of this class and be part of this
@@ -111,6 +225,46 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException()">ApiException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/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>&nbsp;</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/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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#assign(java.util.Collection)">assign(Collection&lt;TopicPartition&gt;)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)">assign(Collection&lt;TopicPartition&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt>
@@ -131,6 +285,10 @@
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#assignment()">assignment()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
+<dt><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>
@@ -171,6 +329,16 @@
 <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/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>
@@ -181,6 +349,10 @@
 <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/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>&nbsp;</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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#bootstrap(java.util.List)">bootstrap(List&lt;InetSocketAddress&gt;)</a></span> - Static method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt>
 <dd>
 <div class="block">Create a "bootstrap" cluster using the given list of host/ports</div>
@@ -193,6 +365,14 @@
 <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&lt;K, V&gt;...)</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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html#BrokerNotAvailableException(java.lang.String)">BrokerNotAvailableException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/BrokerNotAvailableException.html" title="class in org.apache.kafka.common.errors">BrokerNotAvailableException</a></dt>
@@ -203,6 +383,10 @@
 <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
@@ -210,6 +394,38 @@
 </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>&nbsp;</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.String,%20java.lang.Integer)">build(String, 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>&nbsp;</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>
@@ -232,6 +448,10 @@
 <dd>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>
@@ -274,6 +494,10 @@
 <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>&nbsp;</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>
@@ -352,6 +576,40 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringSerializer.html#close()">close()</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization">StringSerializer</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/sink/SinkTask.html#close(java.util.Collection)">close(Collection&lt;TopicPartition&gt;)</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>&nbsp;</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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#closed()">closed()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common"><span class="strong">Cluster</span></a> - Class in <a href="./org/apache/kafka/common/package-summary.html">org.apache.kafka.common</a></dt>
@@ -368,6 +626,19 @@
 <dd>&nbsp;</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>&nbsp;</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 org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync(OffsetCommitCallback)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
@@ -399,6 +670,11 @@
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/CommitFailedException.html#CommitFailedException(java.lang.String)">CommitFailedException(String)</a></span> - Constructor for exception org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/CommitFailedException.html" title="class in org.apache.kafka.clients.consumer">CommitFailedException</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/source/SourceTask.html#commitRecord(org.apache.kafka.connect.source.SourceRecord)">commitRecord(SourceRecord)</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 an individual <a href="./org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source"><code>SourceRecord</code></a> when the callback from the producer client is received.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitSync()">commitSync()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#commitSync(java.util.Map)">commitSync(Map&lt;TopicPartition, OffsetAndMetadata&gt;)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt>
@@ -424,6 +700,8 @@
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#committed(org.apache.kafka.common.TopicPartition)">committed(TopicPartition)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TaskId.html#compareTo(org.apache.kafka.streams.processor.TaskId)">compareTo(TaskId)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TaskId.html" title="class in org.apache.kafka.streams.processor">TaskId</a></dt>
+<dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#completeNext()">completeNext()</a></span> - Method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer">MockProducer</a></dt>
 <dd>
 <div class="block">Complete the earliest uncompleted call successfully.</div>
@@ -436,6 +714,10 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/Config.html#Config(java.util.List)">Config(List&lt;ConfigValue&gt;)</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/connector/Connector.html#config()">config()</a></span> - Method in class org.apache.kafka.connect.connector.<a href="./org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector">Connector</a></dt>
+<dd>
+<div class="block">Define the configuration for the connector.</div>
+</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>
@@ -535,6 +817,12 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/StringSerializer.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.common.serialization.<a href="./org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization">StringSerializer</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/storage/Converter.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in interface org.apache.kafka.connect.storage.<a href="./org/apache/kafka/connect/storage/Converter.html" title="interface in org.apache.kafka.connect.storage">Converter</a></dt>
+<dd>
+<div class="block">Configure this class.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/storage/StringConverter.html#configure(java.util.Map,%20boolean)">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class org.apache.kafka.connect.storage.<a href="./org/apache/kafka/connect/storage/StringConverter.html" title="class in org.apache.kafka.connect.storage">StringConverter</a></dt>
+<dd>&nbsp;</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>&nbsp;</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>
@@ -543,6 +831,16 @@
 <dd>&nbsp;</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>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/connect/errors/ConnectException.html" title="class in org.apache.kafka.connect.errors"><span class="strong">ConnectException</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">ConnectException is the top-level exception type generated by Kafka Connect and connector implementations.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/ConnectException.html#ConnectException(java.lang.String)">ConnectException(String)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/ConnectException.html" title="class in org.apache.kafka.connect.errors">ConnectException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/ConnectException.html#ConnectException(java.lang.String,%20java.lang.Throwable)">ConnectException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/ConnectException.html" title="class in org.apache.kafka.connect.errors">ConnectException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/ConnectException.html#ConnectException(java.lang.Throwable)">ConnectException(Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/ConnectException.html" title="class in org.apache.kafka.connect.errors">ConnectException</a></dt>
+<dd>&nbsp;</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>
@@ -551,6 +849,55 @@
 <dd>
 <div class="block"><code>connections.max.idle.ms</code></div>
 </dd>
+<dt><a href="./org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector"><span class="strong">Connector</span></a> - Class in <a href="./org/apache/kafka/connect/connector/package-summary.html">org.apache.kafka.connect.connector</a></dt>
+<dd>
+<div class="block">
+ Connectors manage integration of Kafka Connect with another system, either as an input that ingests
+ data into Kafka or an output that passes data to an external system.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/connector/Connector.html#Connector()">Connector()</a></span> - Constructor for class org.apache.kafka.connect.connector.<a href="./org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector">Connector</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/connect/connector/ConnectorContext.html" title="interface in org.apache.kafka.connect.connector"><span class="strong">ConnectorContext</span></a> - Interface in <a href="./org/apache/kafka/connect/connector/package-summary.html">org.apache.kafka.connect.connector</a></dt>
+<dd>
+<div class="block">ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.</div>
+</dd>
+<dt><a href="./org/apache/kafka/connect/util/ConnectorUtils.html" title="class in org.apache.kafka.connect.util"><span class="strong">ConnectorUtils</span></a> - Class in <a href="./org/apache/kafka/connect/util/package-summary.html">org.apache.kafka.connect.util</a></dt>
+<dd>
+<div class="block">Utilities that connector implementations might find useful.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/util/ConnectorUtils.html#ConnectorUtils()">ConnectorUtils()</a></span> - Constructor for class org.apache.kafka.connect.util.<a href="./org/apache/kafka/connect/util/ConnectorUtils.html" title="class in org.apache.kafka.connect.util">ConnectorUtils</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#connectProcessorAndStateStores(java.lang.String,%20java.lang.String...)">connectProcessorAndStateStores(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">Connects the processor and the state stores</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#connectProcessors(java.lang.String...)">connectProcessors(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">Connects a list of processors.</div>
+</dd>
+<dt><a href="./org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector"><span class="strong">ConnectRecord</span></a> - Class in <a href="./org/apache/kafka/connect/connector/package-summary.html">org.apache.kafka.connect.connector</a></dt>
+<dd>
+<div class="block">
+ Base class for records containing data to be copied to/from Kafka.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/connector/ConnectRecord.html#ConnectRecord(java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">ConnectRecord(String, Integer, Schema, Object)</a></span> - Constructor for class org.apache.kafka.connect.connector.<a href="./org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector">ConnectRecord</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/connector/ConnectRecord.html#ConnectRecord(java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">ConnectRecord(String, Integer, Schema, Object, Schema, Object)</a></span> - Constructor for class org.apache.kafka.connect.connector.<a href="./org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector">ConnectRecord</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data"><span class="strong">ConnectSchema</span></a> - Class in <a href="./org/apache/kafka/connect/data/package-summary.html">org.apache.kafka.connect.data</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/ConnectSchema.html#ConnectSchema(org.apache.kafka.connect.data.Schema.Type,%20boolean,%20java.lang.Object,%20java.lang.String,%20java.lang.Integer,%20java.lang.String,%20java.util.Map,%20java.util.List,%20org.apache.kafka.connect.data.Schema,%20org.apache.kafka.connect.data.Schema)">ConnectSchema(Schema.Type, boolean, Object, String, Integer, String, Map&lt;String, String&gt;, List&lt;Field&gt;, Schema, Schema)</a></span> - Constructor for class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data">ConnectSchema</a></dt>
+<dd>
+<div class="block">Construct a Schema.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/ConnectSchema.html#ConnectSchema(org.apache.kafka.connect.data.Schema.Type,%20boolean,%20java.lang.Object,%20java.lang.String,%20java.lang.Integer,%20java.lang.String)">ConnectSchema(Schema.Type, boolean, Object, String, Integer, String)</a></span> - Constructor for class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data">ConnectSchema</a></dt>
+<dd>
+<div class="block">Construct a Schema for a primitive type, setting schema parameters, struct fields, and key and value schemas to null.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/ConnectSchema.html#ConnectSchema(org.apache.kafka.connect.data.Schema.Type)">ConnectSchema(Schema.Type)</a></span> - Constructor for class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data">ConnectSchema</a></dt>
+<dd>
+<div class="block">Construct a default schema for a primitive type.</div>
+</dd>
 <dt><a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><span class="strong">Consumer</span></a>&lt;<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="type parameter in Consumer">K</a>,<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="type parameter in Consumer">V</a>&gt; - Interface in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
 <dd>&nbsp;</dd>
 <dt><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">ConsumerConfig</span></a> - Class in <a href="./org/apache/kafka/clients/consumer/package-summary.html">org.apache.kafka.clients.consumer</a></dt>
@@ -587,14 +934,43 @@
 </dd>
 <dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html#ConsumerRecords(java.util.Map)">ConsumerRecords(Map&lt;TopicPartition, List&lt;ConsumerRecord&lt;K, V&gt;&gt;&gt;)</a></span> - Constructor for class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></dt>
 <dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.html" title="class in org.apache.kafka.streams.processor"><span class="strong">ConsumerRecordTimestampExtractor</span></a> - Class in <a href="./org/apache/kafka/streams/processor/package-summary.html">org.apache.kafka.streams.processor</a></dt>
+<dd>
+<div class="block">Retrieves built-in timestamps from Kafka messages (introduced in KIP-32: Add timestamps to Kafka message).</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.html#ConsumerRecordTimestampExtractor()">ConsumerRecordTimestampExtractor()</a></span> - Constructor for class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.html" title="class in org.apache.kafka.streams.processor">ConsumerRecordTimestampExtractor</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/connector/Connector.html#context">context</a></span> - Variable in class org.apache.kafka.connect.connector.<a href="./org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector">Connector</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/sink/SinkTask.html#context">context</a></span> - Variable 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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/source/SourceTask.html#context">context</a></span> - Variable 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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#context()">context()</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">Get the processor's context set during <a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#init(org.apache.kafka.streams.processor.ProcessorContext)"><code>initialization</code></a>.</div>
+</dd>
 <dt><a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors"><span class="strong">ControllerMovedException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/ControllerMovedException.html#ControllerMovedException(java.lang.String)">ControllerMovedException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></dt>
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/errors/ControllerMovedException.html#ControllerMovedException(java.lang.String,%20java.lang.Throwable)">ControllerMovedException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></dt>
 <dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/connect/storage/Converter.html" title="interface in org.apache.kafka.connect.storage"><span class="strong">Converter</span></a> - Interface in <a href="./org/apache/kafka/connect/storage/package-summary.html">org.apache.kafka.connect.storage</a></dt>
+<dd>
+<div class="block">The Converter interface provides support for translating between Kafka Connect's runtime data format
+ and byte[].</div>
+</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#copartitionGroups()">copartitionGroups()</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">Returns the copartition groups.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#copartitionSources(java.util.Collection)">copartitionSources(Collection&lt;String&gt;)</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">Asserts that the streams of the specified source nodes must be copartitioned.</div>
+</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
@@ -612,12 +988,62 @@
 <dd>
 <div class="block">The number of records for all topics</div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KGroupedTable.html#count(java.lang.String)">count(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">Count number of records 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/KStream.html#countByKey(org.apache.kafka.streams.kstream.Windows,%20org.apache.kafka.common.serialization.Serde)">countByKey(Windows&lt;W&gt;, Serde&lt;K&gt;)</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">Count number of records 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/KStream.html#countByKey(org.apache.kafka.streams.kstream.Windows)">countByKey(Windows&lt;W&gt;)</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">Count number of records 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>
+ with default serializers and deserializers.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/KStream.html#countByKey(org.apache.kafka.common.serialization.Serde,%20java.lang.String)">countByKey(Serde&lt;K&gt;, String)</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">Count number of records of this stream by key into a new instance of ever-updating <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/KStream.html#countByKey(java.lang.String)">countByKey(String)</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">Count number of records of this stream by key into a new instance of ever-updating <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a>
+ with default serializers and deserializers.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/Stores.html#create(java.lang.String)">create(String)</a></span> - Static method in class org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/Stores.html" title="class in org.apache.kafka.streams.state">Stores</a></dt>
+<dd>
+<div class="block">Begin to create a new <a href="./org/apache/kafka/streams/processor/StateStoreSupplier.html" title="interface in org.apache.kafka.streams.processor"><code>StateStoreSupplier</code></a> instance.</div>
+</dd>
 </dl>
 <a name="_D_">
 <!--   -->
 </a>
 <h2 class="title">D</h2>
 <dl>
+<dt><a href="./org/apache/kafka/connect/errors/DataException.html" title="class in org.apache.kafka.connect.errors"><span class="strong">DataException</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">Base class for all Kafka Connect data API exceptions.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/DataException.html#DataException(java.lang.String)">DataException(String)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/DataException.html" title="class in org.apache.kafka.connect.errors">DataException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/DataException.html#DataException(java.lang.String,%20java.lang.Throwable)">DataException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/DataException.html" title="class in org.apache.kafka.connect.errors">DataException</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/DataException.html#DataException(java.lang.Throwable)">DataException(Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/DataException.html" title="class in org.apache.kafka.connect.errors">DataException</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/connect/data/Date.html" title="class in org.apache.kafka.connect.data"><span class="strong">Date</span></a> - Class in <a href="./org/apache/kafka/connect/data/package-summary.html">org.apache.kafka.connect.data</a></dt>
+<dd>
+<div class="block">
+     A date representing a calendar day with no time of day or timezone.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Date.html#Date()">Date()</a></span> - Constructor for 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>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/connect/data/Decimal.html" title="class in org.apache.kafka.connect.data"><span class="strong">Decimal</span></a> - Class in <a href="./org/apache/kafka/connect/data/package-summary.html">org.apache.kafka.connect.data</a></dt>
+<dd>
+<div class="block">
+     An arbitrary-precision signed decimal number.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Decimal.html#Decimal()">Decimal()</a></span> - Constructor for 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>&nbsp;</dd>
 <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>&nbsp;</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>
@@ -650,8 +1076,24 @@
 <dd>&nbsp;</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>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/streams/processor/DefaultPartitionGrouper.html" title="class in org.apache.kafka.streams.processor"><span class="strong">DefaultPartitionGrouper</span></a> - Class in <a href="./org/apache/kafka/streams/processor/package-summary.html">org.apache.kafka.streams.processor</a></dt>
+<dd>
+<div class="block">Default implementation of the <a href="./org/apache/kafka/streams/processor/PartitionGrouper.html" title="interface in org.apache.kafka.streams.processor"><code>PartitionGrouper</code></a> interface that groups partitions by the partition id.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/DefaultPartitionGrouper.html#DefaultPartitionGrouper()">DefaultPartitionGrouper()</a></span> - Constructor for class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/DefaultPartitionGrouper.html" title="class in org.apache.kafka.streams.processor">DefaultPartitionGrouper</a></dt>
+<dd>&nbsp;</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/ConnectSchema.html#defaultValue()">defaultValue()</a></span> - Method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data">ConnectSchema</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Schema.html#defaultValue()">defaultValue()</a></span> - Method 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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#defaultValue()">defaultValue()</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#defaultValue(java.lang.Object)">defaultValue(Object)</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">Set the default value for this schema.</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.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&lt;String&gt;, 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>
@@ -712,6 +1154,10 @@
 <dd>
 <div class="block">Define a new configuration with no default value and no special validation logic</div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/state/KeyValueStore.html#delete(K)">delete(K)</a></span> - Method in interface org.apache.kafka.streams.state.<a href="./org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state">KeyValueStore</a></dt>
+<dd>
+<div class="block">Delete the value from the store (if there is one)</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html#dependents">dependents</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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/MetricName.html#description()">description()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a></dt>
@@ -750,6 +1196,16 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html#displayName">displayName</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/ConnectSchema.html#doc()">doc()</a></span> - Method in class org.apache.kafka.connect.data.<a href="./org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data">ConnectSchema</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/Schema.html#doc()">doc()</a></span> - Method 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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#doc()">doc()</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/data/SchemaBuilder.html#doc(java.lang.String)">doc(String)</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">Set the documentation for this schema.</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.ConfigKey.html#documentation">documentation</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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/serialization/Serdes.html#Double()">Double()</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>
@@ -780,6 +1236,10 @@
 <dd>
 <div class="block"><code>enable.auto.commit</code></div>
 </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Window.html#end()">end()</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Window.html" title="class in org.apache.kafka.streams.kstream">Window</a></dt>
+<dd>
+<div class="block">Return the end timestamp of this window, exclusive</div>
+</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.Range.html#ensureValid(java.lang.String,%20java.lang.Object)">ensureValid(String, Object)</a></span> - 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>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.Validator.html#ensureValid(java.lang.String,%20java.lang.Object)">ensureValid(String, Object)</a></span> - Method in interface org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.Validator.html" title="interface in org.apache.kafka.common.config">ConfigDef.Validator</a></dt>
@@ -802,6 +1262,36 @@
 <dd>&nbsp;</dd>
 <dt><span class="strong"><a href="./org/apache/kafka/common/TopicPartition.html#equals(java.lang.Object)">equals(Object)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a></dt>
 <dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/connector/ConnectRecord.html#equals(java.lang.Object)">equals(Object)</a></span> - Method in class org.apache.kafka.connect.connector.<a href="./org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kaf

<TRUNCATED>

Mime
View raw message