kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject [47/51] [partial] kafka-site git commit: Add javadoc for 0.11.0.0
Date Wed, 28 Jun 2017 09:44:36 GMT
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/6699e22d/0110/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/index-all.html b/0110/javadoc/index-all.html
new file mode 100644
index 0000000..2f4f2f9
--- /dev/null
+++ b/0110/javadoc/index-all.html
@@ -0,0 +1,8180 @@
+<!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_80) on Thu Jun 22 23:10:09 BST 2017 -->
+<title>Index (kafka 0.11.0.0 API)</title>
+<meta name="date" content="2017-06-22">
+<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.11.0.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>&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="#_Q_">Q</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>
+<dl>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/KafkaProducer.html#abortTransaction()">abortTransaction()</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">Aborts the ongoing transaction.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#abortTransaction()">abortTransaction()</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#abortTransaction()">abortTransaction()</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">See <a href="./org/apache/kafka/clients/producer/KafkaProducer.html#abortTransaction()"><code>KafkaProducer.abortTransaction()</code></a></div>
+</dd>
+<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&lt;?, ?&gt;, 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>&nbsp;</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&lt;?, ?&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/common/KafkaFuture.BiConsumer.html#accept(A,%20B)">accept(A, B)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaFuture.BiConsumer.html" title="class in org.apache.kafka.common">KafkaFuture.BiConsumer</a></dt>
+<dd>&nbsp;</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><a href="./org/apache/kafka/common/acl/AccessControlEntry.html" title="class in org.apache.kafka.common.acl"><span class="strong">AccessControlEntry</span></a> - Class in <a href="./org/apache/kafka/common/acl/package-summary.html">org.apache.kafka.common.acl</a></dt>
+<dd>
+<div class="block">Represents an access control entry.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/acl/AccessControlEntry.html#AccessControlEntry(java.lang.String,%20java.lang.String,%20org.apache.kafka.common.acl.AclOperation,%20org.apache.kafka.common.acl.AclPermissionType)">AccessControlEntry(String, String, AclOperation, AclPermissionType)</a></span> - Constructor for class org.apache.kafka.common.acl.<a href="./org/apache/kafka/common/acl/AccessControlEntry.html" title="class in org.apache.kafka.common.acl">AccessControlEntry</a></dt>
+<dd>
+<div class="block">Create an instance of an access control entry with the provided parameters.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/acl/AccessControlEntryFilter.html" title="class in org.apache.kafka.common.acl"><span class="strong">AccessControlEntryFilter</span></a> - Class in <a href="./org/apache/kafka/common/acl/package-summary.html">org.apache.kafka.common.acl</a></dt>
+<dd>
+<div class="block">Represents a filter which matches access control entries.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/acl/AccessControlEntryFilter.html#AccessControlEntryFilter(java.lang.String,%20java.lang.String,%20org.apache.kafka.common.acl.AclOperation,%20org.apache.kafka.common.acl.AclPermissionType)">AccessControlEntryFilter(String, String, AclOperation, AclPermissionType)</a></span> - Constructor for class org.apache.kafka.common.acl.<a href="./org/apache/kafka/common/acl/AccessControlEntryFilter.html" title="class in org.apache.kafka.common.acl">AccessControlEntryFilter</a></dt>
+<dd>
+<div class="block">Create an instance of an access control entry filter with the provided parameters.</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><a href="./org/apache/kafka/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl"><span class="strong">AclBinding</span></a> - Class in <a href="./org/apache/kafka/common/acl/package-summary.html">org.apache.kafka.common.acl</a></dt>
+<dd>
+<div class="block">Represents a binding between a resource and an access control entry.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/acl/AclBinding.html#AclBinding(org.apache.kafka.common.resource.Resource,%20org.apache.kafka.common.acl.AccessControlEntry)">AclBinding(Resource, AccessControlEntry)</a></span> - Constructor for class org.apache.kafka.common.acl.<a href="./org/apache/kafka/common/acl/AclBinding.html" title="class in org.apache.kafka.common.acl">AclBinding</a></dt>
+<dd>
+<div class="block">Create an instance of this class with the provided parameters.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl"><span class="strong">AclBindingFilter</span></a> - Class in <a href="./org/apache/kafka/common/acl/package-summary.html">org.apache.kafka.common.acl</a></dt>
+<dd>
+<div class="block">A filter which can match AclBinding objects.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/acl/AclBindingFilter.html#AclBindingFilter(org.apache.kafka.common.resource.ResourceFilter,%20org.apache.kafka.common.acl.AccessControlEntryFilter)">AclBindingFilter(ResourceFilter, AccessControlEntryFilter)</a></span> - Constructor for class org.apache.kafka.common.acl.<a href="./org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a></dt>
+<dd>
+<div class="block">Create an instance of this filter with the provided parameters.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/acl/AclOperation.html" title="enum in org.apache.kafka.common.acl"><span class="strong">AclOperation</span></a> - Enum in <a href="./org/apache/kafka/common/acl/package-summary.html">org.apache.kafka.common.acl</a></dt>
+<dd>
+<div class="block">Represents an operation which an ACL grants or denies permission to perform.</div>
+</dd>
+<dt><a href="./org/apache/kafka/common/acl/AclPermissionType.html" title="enum in org.apache.kafka.common.acl"><span class="strong">AclPermissionType</span></a> - Enum in <a href="./org/apache/kafka/common/acl/package-summary.html">org.apache.kafka.common.acl</a></dt>
+<dd>
+<div class="block">Represents whether an ACL grants or denies permissions.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/header/Headers.html#add(org.apache.kafka.common.header.Header)">add(Header)</a></span> - Method in interface org.apache.kafka.common.header.<a href="./org/apache/kafka/common/header/Headers.html" title="interface in org.apache.kafka.common.header">Headers</a></dt>
+<dd>
+<div class="block">Adds a header (key inside), to the end, returning if the operation succeeded.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/header/Headers.html#add(java.lang.String,%20byte[])">add(String, byte[])</a></span> - Method in interface org.apache.kafka.common.header.<a href="./org/apache/kafka/common/header/Headers.html" title="interface in org.apache.kafka.common.header">Headers</a></dt>
+<dd>
+<div class="block">Creates and adds a header, to the end, returning if the operation succeeded.</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>&nbsp;</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>&nbsp;</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&lt;String, Object&gt;, Deserializer&lt;?&gt;, Deserializer&lt;?&gt;)</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>&nbsp;</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&lt;?&gt;, Deserializer&lt;?&gt;)</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>&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#addGlobalStore(org.apache.kafka.streams.processor.StateStoreSupplier,%20java.lang.String,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.lang.String,%20java.lang.String,%20org.apache.kafka.streams.processor.ProcessorSupplier)">addGlobalStore(StateStoreSupplier&lt;KeyValueStore&gt;, String, Deserializer, Deserializer, String, String, ProcessorSupplier)</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 global <a href="./org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a> to the topology.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addGlobalStore(org.apache.kafka.streams.processor.StateStoreSupplier,%20java.lang.String,%20org.apache.kafka.streams.processor.TimestampExtractor,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.lang.String,%20java.lang.String,%20org.apache.kafka.streams.processor.ProcessorSupplier)">addGlobalStore(StateStoreSupplier&lt;KeyValueStore&gt;, String, TimestampExtractor, Deserializer, Deserializer, String, String, ProcessorSupplier)</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 global <a href="./org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a> to the topology.</div>
+</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#addLatencyAndThroughputSensor(java.lang.String,%20java.lang.String,%20java.lang.String,%20org.apache.kafka.common.metrics.Sensor.RecordingLevel,%20java.lang.String...)">addLatencyAndThroughputSensor(String, String, String, Sensor.RecordingLevel, 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 a latency and throughput sensor for a specific operation, which will include the following sensors:
+ 
+   average latency
+   max latency
+   throughput (num.operations / time unit)
+ 
+ Also create a parent sensor with the same metrics that aggregates all entities with the same operation under the
+ same scope if it has not been created.</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&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/streams/StreamsMetrics.html#addSensor(java.lang.String,%20org.apache.kafka.common.metrics.Sensor.RecordingLevel)">addSensor(String, Sensor.RecordingLevel)</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">Generic method to create a sensor.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsMetrics.html#addSensor(java.lang.String,%20org.apache.kafka.common.metrics.Sensor.RecordingLevel,%20org.apache.kafka.common.metrics.Sensor...)">addSensor(String, Sensor.RecordingLevel, Sensor...)</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">Generic method to create a sensor with parent sensors.</div>
+</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;? super K, ? super 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 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(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20java.lang.String,%20java.lang.String...)">addSource(TopologyBuilder.AutoOffsetReset, 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(org.apache.kafka.streams.processor.TimestampExtractor,%20java.lang.String,%20java.lang.String...)">addSource(TimestampExtractor, 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(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20org.apache.kafka.streams.processor.TimestampExtractor,%20java.lang.String,%20java.lang.String...)">addSource(TopologyBuilder.AutoOffsetReset, TimestampExtractor, 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(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20java.lang.String,%20java.util.regex.Pattern)">addSource(TopologyBuilder.AutoOffsetReset, 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(org.apache.kafka.streams.processor.TimestampExtractor,%20java.lang.String,%20java.util.regex.Pattern)">addSource(TimestampExtractor, 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(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20org.apache.kafka.streams.processor.TimestampExtractor,%20java.lang.String,%20java.util.regex.Pattern)">addSource(TopologyBuilder.AutoOffsetReset, TimestampExtractor, 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(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20java.lang.String,%20org.apache.kafka.streams.processor.TimestampExtractor,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.lang.String...)">addSource(TopologyBuilder.AutoOffsetReset, String, TimestampExtractor, 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#addSource(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20java.lang.String,%20org.apache.kafka.streams.processor.TimestampExtractor,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.util.regex.Pattern)">addSource(TopologyBuilder.AutoOffsetReset, String, TimestampExtractor, 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#addSource(org.apache.kafka.streams.processor.TopologyBuilder.AutoOffsetReset,%20java.lang.String,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer,%20java.util.regex.Pattern)">addSource(TopologyBuilder.AutoOffsetReset, 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/StreamsMetrics.html#addThroughputSensor(java.lang.String,%20java.lang.String,%20java.lang.String,%20org.apache.kafka.common.metrics.Sensor.RecordingLevel,%20java.lang.String...)">addThroughputSensor(String, String, String, Sensor.RecordingLevel, 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 a throughput sensor for a specific operation:
+ 
+   throughput (num.operations / time unit)
+ 
+ Also create a parent sensor with the same metrics that aggregates all entities with the same operation under the
+ same scope if it has not been created.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/KafkaFuture.html#addWaiter(org.apache.kafka.common.KafkaFuture.BiConsumer)">addWaiter(KafkaFuture.BiConsumer&lt;? super T, ? super Throwable&gt;)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaFuture.html" title="class in org.apache.kafka.common">KafkaFuture</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin"><span class="strong">AdminClient</span></a> - Class in <a href="./org/apache/kafka/clients/admin/package-summary.html">org.apache.kafka.clients.admin</a></dt>
+<dd>
+<div class="block">The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/AdminClient.html#AdminClient()">AdminClient()</a></span> - Constructor for class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/clients/admin/AdminClientConfig.html" title="class in org.apache.kafka.clients.admin"><span class="strong">AdminClientConfig</span></a> - Class in <a href="./org/apache/kafka/clients/admin/package-summary.html">org.apache.kafka.clients.admin</a></dt>
+<dd>
+<div class="block">The AdminClient configuration class, which also contains constants for configuration entry names.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/AdminClientConfig.html#AdminClientConfig(java.util.Map)">AdminClientConfig(Map&lt;?, ?&gt;)</a></span> - Constructor for class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/AdminClientConfig.html" title="class in org.apache.kafka.clients.admin">AdminClientConfig</a></dt>
+<dd>&nbsp;</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">Return 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/TimeWindows.html#advanceMs">advanceMs</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 in milliseconds, i.e., 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(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">Changes the end window boundary to <code>timeDifferenceMs</code> but keep the start window boundary as is.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/JoinWindows.html#afterMs">afterMs</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/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&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Serde&lt;VR&gt;, 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 the values of records in this stream by the grouped key.</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)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Serde&lt;VR&gt;)</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 the values of records in this stream by the grouped key.</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.processor.StateStoreSupplier)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, StateStoreSupplier&lt;KeyValueStore&gt;)</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 the values of records in this stream by the grouped key.</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&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Windows&lt;W&gt;, Serde&lt;VR&gt;, 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 the values of records in this stream by the grouped key and defined windows.</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)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Windows&lt;W&gt;, Serde&lt;VR&gt;)</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 the values of records in this stream by the grouped key and defined windows.</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.streams.processor.StateStoreSupplier)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Windows&lt;W&gt;, StateStoreSupplier&lt;WindowStore&gt;)</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 the values of records in this stream by the grouped key and defined windows.</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.Merger,%20org.apache.kafka.streams.kstream.SessionWindows,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String)">aggregate(Initializer&lt;T&gt;, Aggregator&lt;? super K, ? super V, T&gt;, Merger&lt;? super K, T&gt;, SessionWindows, Serde&lt;T&gt;, 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 the values of records in this stream by the grouped key and defined <a href="./org/apache/kafka/streams/kstream/SessionWindows.html" title="class in org.apache.kafka.streams.kstream"><code>SessionWindows</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.Merger,%20org.apache.kafka.streams.kstream.SessionWindows,%20org.apache.kafka.common.serialization.Serde)">aggregate(Initializer&lt;T&gt;, Aggregator&lt;? super K, ? super V, T&gt;, Merger&lt;? super K, T&gt;, SessionWindows, Serde&lt;T&gt;)</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 the values of records in this stream by the grouped key and defined <a href="./org/apache/kafka/streams/kstream/SessionWindows.html" title="class in org.apache.kafka.streams.kstream"><code>SessionWindows</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.Merger,%20org.apache.kafka.streams.kstream.SessionWindows,%20org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.streams.processor.StateStoreSupplier)">aggregate(Initializer&lt;T&gt;, Aggregator&lt;? super K, ? super V, T&gt;, Merger&lt;? super K, T&gt;, SessionWindows, Serde&lt;T&gt;, StateStoreSupplier&lt;SessionStore&gt;)</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 the values of records in this stream by the grouped key and defined <a href="./org/apache/kafka/streams/kstream/SessionWindows.html" title="class in org.apache.kafka.streams.kstream"><code>SessionWindows</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;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Aggregator&lt;? super K, ? super V, VR&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 the value of records of the original <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that got <a href="./org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)"><code>mapped</code></a> to the same 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/KGroupedTable.html#aggregate(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Aggregator)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;)</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 the value of records of the original <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that got <a href="./org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)"><code>mapped</code></a> to the same 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/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;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Serde&lt;VR&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 the value of records of the original <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that got <a href="./org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)"><code>mapped</code></a> to the same 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/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)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Serde&lt;VR&gt;)</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 the value of records of the original <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that got <a href="./org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)"><code>mapped</code></a> to the same 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/KGroupedTable.html#aggregate(org.apache.kafka.streams.kstream.Initializer,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.kstream.Aggregator,%20org.apache.kafka.streams.processor.StateStoreSupplier)">aggregate(Initializer&lt;VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, Aggregator&lt;? super K, ? super V, VR&gt;, StateStoreSupplier&lt;KeyValueStore&gt;)</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 the value of records of the original <a href="./org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><code>KTable</code></a> that got <a href="./org/apache/kafka/streams/kstream/KTable.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)"><code>mapped</code></a> to the same 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>&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">VA</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 <code>Aggregator</code> interface for aggregating values of the given key.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/AlterConfigsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin">AlterConfigsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds only if all the alter configs operations succeed.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/CreateAclsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/CreateAclsResult.html" title="class in org.apache.kafka.clients.admin">CreateAclsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds only if all the ACL creations succeed.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/CreateTopicsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/CreateTopicsResult.html" title="class in org.apache.kafka.clients.admin">CreateTopicsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds if all the topic creations succeed.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/DeleteAclsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/DeleteAclsResult.html" title="class in org.apache.kafka.clients.admin">DeleteAclsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds only if all the ACLs deletions succeed, and which contains all the deleted ACLs.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/DeleteTopicsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/DeleteTopicsResult.html" title="class in org.apache.kafka.clients.admin">DeleteTopicsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds only if all the topic deletions succeed.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/DescribeConfigsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/DescribeConfigsResult.html" title="class in org.apache.kafka.clients.admin">DescribeConfigsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds only if all the config descriptions succeed.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/DescribeTopicsResult.html#all()">all()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/DescribeTopicsResult.html" title="class in org.apache.kafka.clients.admin">DescribeTopicsResult</a></dt>
+<dd>
+<div class="block">Return a future which succeeds only if all the topic descriptions succeed.</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 currently running <code>KafkaStreams</code> instances (potentially remotely) that use the same
+ <a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>application ID</code></a> as this instance (i.e., all instances that belong to
+ the same Kafka Streams application) and return <a href="./org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state"><code>StreamsMetadata</code></a> for each discovered instance.</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 all currently running <code>KafkaStreams</code> instances (potentially remotely) that
+ 
+   use the same <a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG"><code>application ID</code></a> as this instance (i.e., all
+       instances that belong to the same Kafka Streams application)
+   and that contain a <a href="./org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><code>StateStore</code></a> with the given <code>storeName</code>
+ 
+ and return <a href="./org/apache/kafka/streams/state/StreamsMetadata.html" title="class in org.apache.kafka.streams.state"><code>StreamsMetadata</code></a> for each discovered instance.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/KafkaFuture.html#allOf(org.apache.kafka.common.KafkaFuture...)">allOf(KafkaFuture&lt;?&gt;...)</a></span> - Static method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaFuture.html" title="class in org.apache.kafka.common">KafkaFuture</a></dt>
+<dd>
+<div class="block">Returns a new KafkaFuture that is completed when all the given futures have completed.</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, PartitionAssignor.Subscription&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/server/policy/AlterConfigPolicy.html" title="interface in org.apache.kafka.server.policy"><span class="strong">AlterConfigPolicy</span></a> - Interface in <a href="./org/apache/kafka/server/policy/package-summary.html">org.apache.kafka.server.policy</a></dt>
+<dd>
+<div class="block">An interface for enforcing a policy on alter configs requests.</div>
+</dd>
+<dt><a href="./org/apache/kafka/server/policy/AlterConfigPolicy.RequestMetadata.html" title="class in org.apache.kafka.server.policy"><span class="strong">AlterConfigPolicy.RequestMetadata</span></a> - Class in <a href="./org/apache/kafka/server/policy/package-summary.html">org.apache.kafka.server.policy</a></dt>
+<dd>
+<div class="block">Class containing the create request parameters.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/server/policy/AlterConfigPolicy.RequestMetadata.html#AlterConfigPolicy.RequestMetadata(org.apache.kafka.common.config.ConfigResource,%20java.util.Map)">AlterConfigPolicy.RequestMetadata(ConfigResource, Map&lt;String, String&gt;)</a></span> - Constructor for class org.apache.kafka.server.policy.<a href="./org/apache/kafka/server/policy/AlterConfigPolicy.RequestMetadata.html" title="class in org.apache.kafka.server.policy">AlterConfigPolicy.RequestMetadata</a></dt>
+<dd>
+<div class="block">Create an instance of this class with the provided parameters.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map)">alterConfigs(Map&lt;ConfigResource, Config&gt;)</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a></dt>
+<dd>
+<div class="block">Update the configuration for the specified resources with the default options.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map,%20org.apache.kafka.clients.admin.AlterConfigsOptions)">alterConfigs(Map&lt;ConfigResource, Config&gt;, AlterConfigsOptions)</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin">AdminClient</a></dt>
+<dd>
+<div class="block">Update the configuration for the specified resources with the default options.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/KafkaAdminClient.html#alterConfigs(java.util.Map,%20org.apache.kafka.clients.admin.AlterConfigsOptions)">alterConfigs(Map&lt;ConfigResource, Config&gt;, AlterConfigsOptions)</a></span> - Method in class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/KafkaAdminClient.html" title="class in org.apache.kafka.clients.admin">KafkaAdminClient</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/clients/admin/AlterConfigsOptions.html" title="class in org.apache.kafka.clients.admin"><span class="strong">AlterConfigsOptions</span></a> - Class in <a href="./org/apache/kafka/clients/admin/package-summary.html">org.apache.kafka.clients.admin</a></dt>
+<dd>
+<div class="block">Options for <a href="./org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map)"><code>AdminClient.alterConfigs(Map)</code></a>.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/admin/AlterConfigsOptions.html#AlterConfigsOptions()">AlterConfigsOptions()</a></span> - Constructor for class org.apache.kafka.clients.admin.<a href="./org/apache/kafka/clients/admin/AlterConfigsOptions.html" title="class in org.apache.kafka.clients.admin">AlterConfigsOptions</a></dt>
+<dd>&nbsp;</dd>
+<dt><a href="./org/apache/kafka/clients/admin/AlterConfigsResult.html" title="class in org.apache.kafka.clients.admin"><span class="strong">AlterConfigsResult</span></a> - Class in <a href="./org/apache/kafka/clients/admin/package-summary.html">org.apache.kafka.clients.admin</a></dt>
+<dd>
+<div class="block">The result of the <a href="./org/apache/kafka/clients/admin/AdminClient.html#alterConfigs(java.util.Map)"><code>AdminClient.alterConfigs(Map)</code></a> call.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/acl/AccessControlEntryFilter.html#ANY">ANY</a></span> - Static variable in class org.apache.kafka.common.acl.<a href="./org/apache/kafka/common/acl/AccessControlEntryFilter.html" title="class in org.apache.kafka.common.acl">AccessControlEntryFilter</a></dt>
+<dd>
+<div class="block">Matches any access control entry.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/acl/AclBindingFilter.html#ANY">ANY</a></span> - Static variable in class org.apache.kafka.common.acl.<a href="./org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl">AclBindingFilter</a></dt>
+<dd>
+<div class="block">A filter which matches any ACL binding.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/resource/ResourceFilter.html#ANY">ANY</a></span> - Static variable in class org.apache.kafka.common.resource.<a href="./org/apache/kafka/common/resource/ResourceFilter.html" title="class in org.apache.kafka.common.resource">ResourceFilter</a></dt>
+<dd>
+<div class="block">Matches any resource.</div>
+</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>&nbsp;</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>&nbsp;</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>&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/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_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/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/common/KafkaFuture.Function.html#apply(A)">apply(A)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/KafkaFuture.Function.html" title="class in org.apache.kafka.common">KafkaFuture.Function</a></dt>
+<dd>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/connect/transforms/Transformation.html#apply(R)">apply(R)</a></span> - Method in interface org.apache.kafka.connect.transforms.<a href="./org/apache/kafka/connect/transforms/Transformation.html" title="interface in org.apache.kafka.connect.transforms">Transformation</a></dt>
+<dd>
+<div class="block">Apply transformation to the <code>record</code> and return another record object (which may be <code>record</code> itself) or <code>null</code>,
+ corresponding to a map or filter operation respectively.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/Aggregator.html#apply(K,%20V,%20VA)">apply(K, V, VA)</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/Merger.html#apply(K,%20V,%20V)">apply(K, V, V)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/Merger.html" title="interface in org.apache.kafka.streams.kstream">Merger</a></dt>
+<dd>
+<div class="block">Compute a new aggregate from the key and two aggregates.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/PrintForeachAction.html#apply(K,%20V)">apply(K, V)</a></span> - Method in class org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/PrintForeachAction.html" title="class in org.apache.kafka.streams.kstream">PrintForeachAction</a></dt>
+<dd>&nbsp;</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(V)">apply(V)</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>&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>
+<dd>
+<div class="block">Manually assign a list of partitions to this consumer.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.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/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/consumer/RangeAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map&lt;String, Integer&gt;, Map&lt;String, PartitionAssignor.Subscription&gt;)</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map&lt;String, Integer&gt;, Map&lt;String, PartitionAssignor.Subscription&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><span class="strong"><a href="./org/apache/kafka/clients/consumer/StickyAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map&lt;String, Integer&gt;, Map&lt;String, PartitionAssignor.Subscription&gt;)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/StickyAssignor.html" title="class in org.apache.kafka.clients.consumer">StickyAssignor</a></dt>
+<dd>&nbsp;</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>&nbsp;</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>&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/streams/StreamsConfig.html#AT_LEAST_ONCE">AT_LEAST_ONCE</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">Config value for parameter <a href="./org/apache/kafka/streams/StreamsConfig.html#PROCESSING_GUARANTEE_CONFIG"><code>"processing.guarantee"</code></a> for at-least-once processing guarantees.</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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(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">Changes the start window boundary to <code>timeDifferenceMs</code> but keep the end window boundary as is.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/JoinWindows.html#beforeMs">beforeMs</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/clients/consumer/Consumer.html#beginningOffsets(java.util.Collection)">beginningOffsets(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#beginningOffsets(java.util.Collection)">beginningOffsets(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>
+<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&lt;TopicPartition&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/KafkaProducer.html#beginTransaction()">beginTransaction()</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">Should be called before the start of each new transaction.</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/MockProducer.html#beginTransaction()">beginTransaction()</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>&nbsp;</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/Producer.html#beginTransaction()">beginTransaction()</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">See <a href="./org/apache/kafka/clients/producer/KafkaProducer.html#beginTransaction()"><code>KafkaProducer.beginTransaction()</code></a></div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigDef.Range.html#between(java.lang.Number,%20java.lang.Number)">between(Number, Number)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigDef.Range.html" title="class in org.apache.kafka.common.config">ConfigDef.Range</a></dt>
+<dd>
+<div class="block">A numeric range that checks both the upper and lower bound</div>
+</dd>
+<dt><span class="strong"><a href="./org/apache/kafka/clients

<TRUNCATED>

Mime
View raw message