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> <a href="#_B_">B</a> <a href="#_C_">C</a> <a href="#_D_">D</a> <a href="#_E_">E</a> <a href="#_F_">F</a> <a href="#_G_">G</a> <a href="#_H_">H</a> <a href="#_I_">I</a> <a href="#_J_">J</a> <a href="#_K_">K</a> <a href="#_L_">L</a> <a href="#_M_">M</a> <a href="#_N_">N</a> <a href="#_O_">O</a> <a href="#_P_">P</a> <a href="#_Q_">Q</a> <a href="#_R_">R</a> <a href="#_S_">S</a> <a href="#_T_">T</a> <a href="#_U_">U</a> <a href="#_V_">V</a> <a href="#_W_">W</a> <a href="#_Z_">Z</a> <a name="_A_"> +<!-- --> +</a> +<h2 class="title">A</h2> +<dl> +<dt><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> </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<?, ?>, boolean)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config">AbstractConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig(org.apache.kafka.common.config.ConfigDef,%20java.util.Map)">AbstractConfig(ConfigDef, Map<?, ?>)</a></span> - Constructor for class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config">AbstractConfig</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor"><span class="strong">AbstractProcessor</span></a><<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="type parameter in AbstractProcessor">K</a>,<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="type parameter in AbstractProcessor">V</a>> - Class in <a href="./org/apache/kafka/streams/processor/package-summary.html">org.apache.kafka.streams.processor</a></dt> +<dd> +<div class="block">An abstract implementation of <a href="./org/apache/kafka/streams/processor/Processor.html" title="interface in org.apache.kafka.streams.processor"><code>Processor</code></a> that manages the <a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor"><code>ProcessorContext</code></a> instance and provides default no-op + implementations of <a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#punctuate(long)"><code>AbstractProcessor.punctuate(long)</code></a> and <a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#close()"><code>AbstractProcessor.close()</code></a>.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/AbstractProcessor.html#AbstractProcessor()">AbstractProcessor()</a></span> - Constructor for class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor">AbstractProcessor</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/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> </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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/SslConfigs.html#addClientSslSupport(org.apache.kafka.common.config.ConfigDef)">addClientSslSupport(ConfigDef)</a></span> - Static method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig(java.util.Map,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">addDeserializerToConfig(Map<String, Object>, Deserializer<?>, Deserializer<?>)</a></span> - Static method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">addDeserializerToConfig(Properties, Deserializer<?>, Deserializer<?>)</a></span> - Static method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/config/ConfigValue.html#addErrorMessage(java.lang.String)">addErrorMessage(String)</a></span> - Method in class org.apache.kafka.common.config.<a href="./org/apache/kafka/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config">ConfigValue</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#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<KeyValueStore>, 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<KeyValueStore>, 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<K, V>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/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<String, Object>, Serializer<?>, Serializer<?>)</a></span> - Static method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig(java.util.Properties,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer)">addSerializerToConfig(Properties, Serializer<?>, Serializer<?>)</a></span> - Static method in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20java.lang.String...)">addSink(String, String, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String...)">addSink(String, String, StreamPartitioner, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic, using + the supplied partitioner.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer,%20java.lang.String...)">addSink(String, String, Serializer, Serializer, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSink(java.lang.String,%20java.lang.String,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.common.serialization.Serializer,%20org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String...)">addSink(String, String, Serializer<K>, Serializer<V>, StreamPartitioner<? super K, ? super V>, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to the named Kafka topic.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSource(java.lang.String,%20java.lang.String...)">addSource(String, String...)</a></span> - Method in class org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></dt> +<dd> +<div class="block">Add a new source that consumes the named topics and forward the records to child processor and/or sink nodes.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/TopologyBuilder.html#addSource(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<? super T, ? super Throwable>)</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> </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> </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<?, ?>)</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> </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<VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>, 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<VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>)</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<VR>, Aggregator<? super K, ? super V, VR>, StateStoreSupplier<KeyValueStore>)</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<VR>, Aggregator<? super K, ? super V, VR>, Windows<W>, Serde<VR>, 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<VR>, Aggregator<? super K, ? super V, VR>, Windows<W>, Serde<VR>)</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<VR>, Aggregator<? super K, ? super V, VR>, Windows<W>, StateStoreSupplier<WindowStore>)</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<T>, Aggregator<? super K, ? super V, T>, Merger<? super K, T>, SessionWindows, Serde<T>, String)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="./org/apache/kafka/streams/kstream/KGroupedStream.html" title="interface in org.apache.kafka.streams.kstream">KGroupedStream</a></dt> +<dd> +<div class="block">Aggregate 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<T>, Aggregator<? super K, ? super V, T>, Merger<? super K, T>, SessionWindows, Serde<T>)</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<T>, Aggregator<? super K, ? super V, T>, Merger<? super K, T>, SessionWindows, Serde<T>, StateStoreSupplier<SessionStore>)</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<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, 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<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>)</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<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>, 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<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>)</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<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, StateStoreSupplier<KeyValueStore>)</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><<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>> - 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<?>...)</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<String, Integer>, Map<String, PartitionAssignor.Subscription>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors"><span class="strong">AlreadyExistsException</span></a> - Exception in <a href="./org/apache/kafka/connect/errors/package-summary.html">org.apache.kafka.connect.errors</a></dt> +<dd> +<div class="block">Indicates the operation tried to create an entity that already exists.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html#AlreadyExistsException(java.lang.String)">AlreadyExistsException(String)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html#AlreadyExistsException(java.lang.String,%20java.lang.Throwable)">AlreadyExistsException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html#AlreadyExistsException(java.lang.Throwable)">AlreadyExistsException(Throwable)</a></span> - Constructor for exception org.apache.kafka.connect.errors.<a href="./org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/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<String, String>)</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<ConfigResource, Config>)</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<ConfigResource, Config>, 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<ConfigResource, Config>, 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> </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> </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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.String)">ApiException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException(java.lang.Throwable)">ApiException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/ApiException.html#ApiException()">ApiException()</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/ProcessorContext.html#appConfigs()">appConfigs()</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor">ProcessorContext</a></dt> +<dd> +<div class="block">Returns all the application config properties as key/value pairs.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/processor/ProcessorContext.html#appConfigsWithPrefix(java.lang.String)">appConfigsWithPrefix(String)</a></span> - Method in interface org.apache.kafka.streams.processor.<a href="./org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor">ProcessorContext</a></dt> +<dd> +<div class="block">Returns all the application config properties with the given key prefix, as key/value pairs + stripping the prefix.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG">APPLICATION_ID_CONFIG</a></span> - Static variable in class org.apache.kafka.streams.<a href="./org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></dt> +<dd> +<div class="block"><code>application.id</code></div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/StreamsConfig.html#APPLICATION_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> </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> </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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#assign(java.util.Collection)">assign(Collection<TopicPartition>)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)">assign(Collection<TopicPartition>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Manually assign a list of 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<TopicPartition>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RangeAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RangeAssignor.html" title="class in org.apache.kafka.clients.consumer">RangeAssignor</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/StickyAssignor.html#assign(java.util.Map,%20java.util.Map)">assign(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)</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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/Consumer.html#assignment()">assignment()</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#assignment()">assignment()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Get the set of partitions currently assigned to this consumer.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#assignment()">assignment()</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/connect/sink/SinkTaskContext.html#assignment()">assignment()</a></span> - Method in interface org.apache.kafka.connect.sink.<a href="./org/apache/kafka/connect/sink/SinkTaskContext.html" title="interface in org.apache.kafka.connect.sink">SinkTaskContext</a></dt> +<dd> +<div class="block">Get the current set of assigned TopicPartitions for this task.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/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> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthenticationException.html#AuthenticationException(java.lang.String)">AuthenticationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors">AuthenticationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthenticationException.html#AuthenticationException(java.lang.String,%20java.lang.Throwable)">AuthenticationException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors">AuthenticationException</a></dt> +<dd> </dd> +<dt><a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors"><span class="strong">AuthorizationException</span></a> - Exception in <a href="./org/apache/kafka/common/errors/package-summary.html">org.apache.kafka.common.errors</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthorizationException.html#AuthorizationException(java.lang.String)">AuthorizationException(String)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/errors/AuthorizationException.html#AuthorizationException(java.lang.String,%20java.lang.Throwable)">AuthorizationException(String, Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_COMMIT_INTERVAL_MS_CONFIG">AUTO_COMMIT_INTERVAL_MS_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt> +<dd> +<div class="block"><code>auto.commit.interval.ms</code></div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_OFFSET_RESET_CONFIG">AUTO_OFFSET_RESET_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt> +<dd> +<div class="block"><code>auto.offset.reset</code></div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_OFFSET_RESET_DOC">AUTO_OFFSET_RESET_DOC</a></span> - Static variable in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/common/Cluster.html#availablePartitionsForTopic(java.lang.String)">availablePartitionsForTopic(String)</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a></dt> +<dd> +<div class="block">Get the list of available partitions for this topic</div> +</dd> +</dl> +<a name="_B_"> +<!-- --> +</a> +<h2 class="title">B</h2> +<dl> +<dt><span class="strong"><a href="./org/apache/kafka/clients/producer/ProducerConfig.html#BATCH_SIZE_CONFIG">BATCH_SIZE_CONFIG</a></span> - Static variable in class org.apache.kafka.clients.producer.<a href="./org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></dt> +<dd> +<div class="block"><code>batch.size</code></div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/streams/kstream/JoinWindows.html#before(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<TopicPartition>)</a></span> - Method in interface org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html#beginningOffsets(java.util.Collection)">beginningOffsets(Collection<TopicPartition>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></dt> +<dd> +<div class="block">Get the first offset for the given partitions.</div> +</dd> +<dt><span class="strong"><a href="./org/apache/kafka/clients/consumer/MockConsumer.html#beginningOffsets(java.util.Collection)">beginningOffsets(Collection<TopicPartition>)</a></span> - Method in class org.apache.kafka.clients.consumer.<a href="./org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer">MockConsumer</a></dt> +<dd> </dd> +<dt><span class="strong"><a href="./org/apache/kafka/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> </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>
