Added: release/kafka/2.6.0/javadoc/index-all.html ============================================================================== --- release/kafka/2.6.0/javadoc/index-all.html (added) +++ release/kafka/2.6.0/javadoc/index-all.html Tue Aug 4 22:01:33 2020 @@ -0,0 +1,15145 @@ +<!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 --> +<title>Index (kafka 2.6.0 API)</title> +<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> +<script type="text/javascript" src="script.js"></script> +</head> +<body> +<script type="text/javascript"><!-- + try { + if (location.href.indexOf('is-external=true') == -1) { + parent.document.title="Index (kafka 2.6.0 API)"; + } + } + catch(err) { + } +//--> +</script> +<noscript> +<div>JavaScript is disabled on your browser.</div> +</noscript> +<!-- ========= START OF TOP NAVBAR ======= --> +<div class="topNav"><a name="navbar.top"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> +<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="#I:A">A</a> <a href="#I:B">B</a> <a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:I">I</a> <a href="#I:J">J</a> <a href="#I:K">K</a> <a href="#I:L">L</a> <a href="#I:M">M</a> <a href="#I:N">N</a> <a href="#I:O">O</a> <a href="#I:P">P</a> <a href="#I:Q">Q</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:U">U</a> <a href="#I:V">V</a> <a href="#I:W">W</a> <a name="I:A"> +<!-- --> +</a> +<h2 class="title">A</h2> +<dl> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.html#abort--">abort()</a></span> - Method in class org.apache.kafka.common.security.oauthbearer.<a href="org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.html" title="class in org.apache.kafka.common.security.oauthbearer">OAuthBearerLoginModule</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/security/plain/PlainLoginModule.html#abort--">abort()</a></span> - Method in class org.apache.kafka.common.security.plain.<a href="org/apache/kafka/common/security/plain/PlainLoginModule.html" title="class in org.apache.kafka.common.security.plain">PlainLoginModule</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/security/scram/ScramLoginModule.html#abort--">abort()</a></span> - Method in class org.apache.kafka.common.security.scram.<a href="org/apache/kafka/common/security/scram/ScramLoginModule.html" title="class in org.apache.kafka.common.security.scram">ScramLoginModule</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><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="memberNameLink"><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="memberNameLink"><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><span class="memberNameLink"><a href="org/apache/kafka/clients/producer/MockProducer.html#abortTransactionException">abortTransactionException</a></span> - Variable 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><a href="org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config"><span class="typeNameLink">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="memberNameLink"><a href="org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig-org.apache.kafka.common.config.ConfigDef-java.util.Map-java.util.Map-boolean-">AbstractConfig(ConfigDef, Map<?, ?>, Map<String, ?>, 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> +<div class="block">Construct a configuration with a ConfigDef and the configuration properties, which can include properties + for zero or more <a href="org/apache/kafka/common/config/provider/ConfigProvider.html" title="interface in org.apache.kafka.common.config.provider"><code>ConfigProvider</code></a> that will be used to resolve variables in configuration property + values.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig-org.apache.kafka.common.config.ConfigDef-java.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> +<div class="block">Construct a configuration with a ConfigDef and the configuration properties, + which can include properties for zero or more <a href="org/apache/kafka/common/config/provider/ConfigProvider.html" title="interface in org.apache.kafka.common.config.provider"><code>ConfigProvider</code></a> + that will be used to resolve variables in configuration property values.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/config/AbstractConfig.html#AbstractConfig-org.apache.kafka.common.config.ConfigDef-java.util.Map-boolean-">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> +<div class="block">Construct a configuration with a ConfigDef and the configuration properties, + which can include properties for zero or more <a href="org/apache/kafka/common/config/provider/ConfigProvider.html" title="interface in org.apache.kafka.common.config.provider"><code>ConfigProvider</code></a> + that will be used to resolve variables in configuration property values.</div> +</dd> +<dt><a href="org/apache/kafka/clients/admin/AbstractOptions.html" title="class in org.apache.kafka.clients.admin"><span class="typeNameLink">AbstractOptions</span></a><<a href="org/apache/kafka/clients/admin/AbstractOptions.html" title="type parameter in AbstractOptions">T</a> extends <a href="org/apache/kafka/clients/admin/AbstractOptions.html" title="class in org.apache.kafka.clients.admin">AbstractOptions</a>> - Class in <a href="org/apache/kafka/clients/admin/package-summary.html">org.apache.kafka.clients.admin</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/clients/admin/AbstractOptions.html#AbstractOptions--">AbstractOptions()</a></span> - Constructor for class org.apache.kafka.clients.admin.<a href="org/apache/kafka/clients/admin/AbstractOptions.html" title="class in org.apache.kafka.clients.admin">AbstractOptions</a></dt> +<dd> </dd> +<dt><a href="org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor"><span class="typeNameLink">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 + implementation of <a href="org/apache/kafka/streams/processor/AbstractProcessor.html#close--"><code>AbstractProcessor.close()</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><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><a href="org/apache/kafka/connect/health/AbstractState.html" title="class in org.apache.kafka.connect.health"><span class="typeNameLink">AbstractState</span></a> - Class in <a href="org/apache/kafka/connect/health/package-summary.html">org.apache.kafka.connect.health</a></dt> +<dd> +<div class="block">Provides the current status along with identifier for Connect worker and tasks.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/health/AbstractState.html#AbstractState-java.lang.String-java.lang.String-java.lang.String-">AbstractState(String, String, String)</a></span> - Constructor for class org.apache.kafka.connect.health.<a href="org/apache/kafka/connect/health/AbstractState.html" title="class in org.apache.kafka.connect.health">AbstractState</a></dt> +<dd> +<div class="block">Construct a state for connector or task.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/KafkaFuture.BiConsumer.html#accept-A-B-">accept(A, B)</a></span> - Method in interface org.apache.kafka.common.<a href="org/apache/kafka/common/KafkaFuture.BiConsumer.html" title="interface in org.apache.kafka.common">KafkaFuture.BiConsumer</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsConfig.html#ACCEPTABLE_RECOVERY_LAG_CONFIG">ACCEPTABLE_RECOVERY_LAG_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>acceptable.recovery.lag</code></div> +</dd> +<dt><span class="memberNameLink"><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="typeNameLink">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="memberNameLink"><a href="org/apache/kafka/common/acl/AccessControlEntry.html#AccessControlEntry-java.lang.String-java.lang.String-org.apache.kafka.common.acl.AclOperation-org.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="typeNameLink">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="memberNameLink"><a href="org/apache/kafka/common/acl/AccessControlEntryFilter.html#AccessControlEntryFilter-java.lang.String-java.lang.String-org.apache.kafka.common.acl.AclOperation-org.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="memberNameLink"><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="typeNameLink">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 pattern and an access control entry.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/common/acl/AclBinding.html#AclBinding-org.apache.kafka.common.resource.ResourcePattern-org.apache.kafka.common.acl.AccessControlEntry-">AclBinding(ResourcePattern, 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><span class="memberNameLink"><a href="org/apache/kafka/common/acl/AclBinding.html#AclBinding-org.apache.kafka.common.resource.Resource-org.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"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Since 2.0. Use <a href="org/apache/kafka/common/acl/AclBinding.html#AclBinding-org.apache.kafka.common.resource.ResourcePattern-org.apache.kafka.common.acl.AccessControlEntry-"><code>AclBinding.AclBinding(ResourcePattern, AccessControlEntry)</code></a></span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html#aclBinding--">aclBinding()</a></span> - Method in class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html" title="class in org.apache.kafka.server.authorizer">AclDeleteResult.AclBindingDeleteResult</a></dt> +<dd> +<div class="block">Returns ACL binding that matched the delete filter.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html#AclBindingDeleteResult-org.apache.kafka.common.acl.AclBinding-">AclBindingDeleteResult(AclBinding)</a></span> - Constructor for class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html" title="class in org.apache.kafka.server.authorizer">AclDeleteResult.AclBindingDeleteResult</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html#AclBindingDeleteResult-org.apache.kafka.common.acl.AclBinding-org.apache.kafka.common.errors.ApiException-">AclBindingDeleteResult(AclBinding, ApiException)</a></span> - Constructor for class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html" title="class in org.apache.kafka.server.authorizer">AclDeleteResult.AclBindingDeleteResult</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclDeleteResult.html#aclBindingDeleteResults--">aclBindingDeleteResults()</a></span> - Method in class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclDeleteResult.html" title="class in org.apache.kafka.server.authorizer">AclDeleteResult</a></dt> +<dd> +<div class="block">Returns delete result for each matching ACL binding.</div> +</dd> +<dt><a href="org/apache/kafka/common/acl/AclBindingFilter.html" title="class in org.apache.kafka.common.acl"><span class="typeNameLink">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="memberNameLink"><a href="org/apache/kafka/common/acl/AclBindingFilter.html#AclBindingFilter-org.apache.kafka.common.resource.ResourcePatternFilter-org.apache.kafka.common.acl.AccessControlEntryFilter-">AclBindingFilter(ResourcePatternFilter, 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><span class="memberNameLink"><a href="org/apache/kafka/common/acl/AclBindingFilter.html#AclBindingFilter-org.apache.kafka.common.resource.ResourceFilter-org.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"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Since 2.0. Use <a href="org/apache/kafka/common/acl/AclBindingFilter.html#AclBindingFilter-org.apache.kafka.common.resource.ResourcePatternFilter-org.apache.kafka.common.acl.AccessControlEntryFilter-"><code>AclBindingFilter.AclBindingFilter(ResourcePatternFilter, AccessControlEntryFilter)</code></a></span></div> +</div> +</dd> +<dt><a href="org/apache/kafka/server/authorizer/AclCreateResult.html" title="class in org.apache.kafka.server.authorizer"><span class="typeNameLink">AclCreateResult</span></a> - Class in <a href="org/apache/kafka/server/authorizer/package-summary.html">org.apache.kafka.server.authorizer</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclCreateResult.html#AclCreateResult-org.apache.kafka.common.errors.ApiException-">AclCreateResult(ApiException)</a></span> - Constructor for class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclCreateResult.html" title="class in org.apache.kafka.server.authorizer">AclCreateResult</a></dt> +<dd> </dd> +<dt><a href="org/apache/kafka/server/authorizer/AclDeleteResult.html" title="class in org.apache.kafka.server.authorizer"><span class="typeNameLink">AclDeleteResult</span></a> - Class in <a href="org/apache/kafka/server/authorizer/package-summary.html">org.apache.kafka.server.authorizer</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclDeleteResult.html#AclDeleteResult-org.apache.kafka.common.errors.ApiException-">AclDeleteResult(ApiException)</a></span> - Constructor for class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclDeleteResult.html" title="class in org.apache.kafka.server.authorizer">AclDeleteResult</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/AclDeleteResult.html#AclDeleteResult-java.util.Collection-">AclDeleteResult(Collection<AclDeleteResult.AclBindingDeleteResult>)</a></span> - Constructor for class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/AclDeleteResult.html" title="class in org.apache.kafka.server.authorizer">AclDeleteResult</a></dt> +<dd> </dd> +<dt><a href="org/apache/kafka/server/authorizer/AclDeleteResult.AclBindingDeleteResult.html" title="class in org.apache.kafka.server.authorizer"><span class="typeNameLink">AclDeleteResult.AclBindingDeleteResult</span></a> - Class in <a href="org/apache/kafka/server/authorizer/package-summary.html">org.apache.kafka.server.authorizer</a></dt> +<dd> +<div class="block">Delete result for each ACL binding that matched a delete filter.</div> +</dd> +<dt><a href="org/apache/kafka/common/acl/AclOperation.html" title="enum in org.apache.kafka.common.acl"><span class="typeNameLink">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="typeNameLink">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="memberNameLink"><a href="org/apache/kafka/server/authorizer/Authorizer.html#acls-org.apache.kafka.common.acl.AclBindingFilter-">acls(AclBindingFilter)</a></span> - Method in interface org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/Authorizer.html" title="interface in org.apache.kafka.server.authorizer">Authorizer</a></dt> +<dd> +<div class="block">Returns ACL bindings which match the provided filter.</div> +</dd> +<dt><a href="org/apache/kafka/server/authorizer/Action.html" title="class in org.apache.kafka.server.authorizer"><span class="typeNameLink">Action</span></a> - Class in <a href="org/apache/kafka/server/authorizer/package-summary.html">org.apache.kafka.server.authorizer</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/server/authorizer/Action.html#Action-org.apache.kafka.common.acl.AclOperation-org.apache.kafka.common.resource.ResourcePattern-int-boolean-boolean-">Action(AclOperation, ResourcePattern, int, boolean, boolean)</a></span> - Constructor for class org.apache.kafka.server.authorizer.<a href="org/apache/kafka/server/authorizer/Action.html" title="class in org.apache.kafka.server.authorizer">Action</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/processor/ThreadMetadata.html#activeTasks--">activeTasks()</a></span> - Method in class org.apache.kafka.streams.processor.<a href="org/apache/kafka/streams/processor/ThreadMetadata.html" title="class in org.apache.kafka.streams.processor">ThreadMetadata</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/common/header/Headers.html#add-java.lang.String-byte:A-">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="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#add-org.apache.kafka.connect.header.Header-">add(Header)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#add-java.lang.String-org.apache.kafka.connect.data.SchemaAndValue-">add(String, SchemaAndValue)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#add-java.lang.String-java.lang.Object-org.apache.kafka.connect.data.Schema-">add(String, Object, Schema)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#add-org.apache.kafka.connect.header.Header-">add(Header)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add the given <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> to this collection.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#add-java.lang.String-org.apache.kafka.connect.data.SchemaAndValue-">add(String, SchemaAndValue)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#add-java.lang.String-java.lang.Object-org.apache.kafka.connect.data.Schema-">add(String, Object, Schema)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addBoolean-java.lang.String-boolean-">addBoolean(String, boolean)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addBoolean-java.lang.String-boolean-">addBoolean(String, boolean)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addByte-java.lang.String-byte-">addByte(String, byte)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addByte-java.lang.String-byte-">addByte(String, byte)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addBytes-java.lang.String-byte:A-">addBytes(String, byte[])</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addBytes-java.lang.String-byte:A-">addBytes(String, byte[])</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><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="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addDate-java.lang.String-java.util.Date-">addDate(String, Date)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addDate-java.lang.String-java.util.Date-">addDate(String, Date)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and <a href="org/apache/kafka/connect/data/Date.html" title="class in org.apache.kafka.connect.data"><code>Date</code></a> value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addDecimal-java.lang.String-java.math.BigDecimal-">addDecimal(String, BigDecimal)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addDecimal-java.lang.String-java.math.BigDecimal-">addDecimal(String, BigDecimal)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and <a href="org/apache/kafka/connect/data/Decimal.html" title="class in org.apache.kafka.connect.data"><code>Decimal</code></a> value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig-java.util.Map-org.apache.kafka.common.serialization.Deserializer-org.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="memberNameLink"><a href="org/apache/kafka/clients/consumer/ConsumerConfig.html#addDeserializerToConfig-java.util.Properties-org.apache.kafka.common.serialization.Deserializer-org.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="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addDouble-java.lang.String-double-">addDouble(String, double)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addDouble-java.lang.String-double-">addDouble(String, double)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addFloat-java.lang.String-float-">addFloat(String, float)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addFloat-java.lang.String-float-">addFloat(String, float)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsBuilder.html#addGlobalStore-org.apache.kafka.streams.state.StoreBuilder-java.lang.String-java.lang.String-org.apache.kafka.streams.kstream.Consumed-java.lang.String-org.apache.kafka.streams.processor.ProcessorSupplier-">addGlobalStore(StoreBuilder<?>, String, String, Consumed<K, V>, String, ProcessorSupplier<K, V>)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/StreamsBuilder.html" title="class in org.apache.kafka.streams">StreamsBuilder</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">use <a href="org/apache/kafka/streams/StreamsBuilder.html#addGlobalStore-org.apache.kafka.streams.state.StoreBuilder-java.lang.String-org.apache.kafka.streams.kstream.Consumed-org.apache.kafka.streams.processor.ProcessorSupplier-"><code>StreamsBuilder.addGlobalStore(StoreBuilder, String, Consumed, ProcessorSupplier)</code></a> instead</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsBuilder.html#addGlobalStore-org.apache.kafka.streams.state.StoreBuilder-java.lang.String-org.apache.kafka.streams.kstream.Consumed-org.apache.kafka.streams.processor.ProcessorSupplier-">addGlobalStore(StoreBuilder<?>, String, Consumed<K, V>, ProcessorSupplier<K, V>)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/StreamsBuilder.html" title="class in org.apache.kafka.streams">StreamsBuilder</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addGlobalStore-org.apache.kafka.streams.state.StoreBuilder-java.lang.String-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.lang.String-java.lang.String-org.apache.kafka.streams.processor.ProcessorSupplier-">addGlobalStore(StoreBuilder<?>, String, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V>)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addGlobalStore-org.apache.kafka.streams.state.StoreBuilder-java.lang.String-org.apache.kafka.streams.processor.TimestampExtractor-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.lang.String-java.lang.String-org.apache.kafka.streams.processor.ProcessorSupplier-">addGlobalStore(StoreBuilder<?>, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V>)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/clients/admin/PartitionReassignment.html#addingReplicas--">addingReplicas()</a></span> - Method in class org.apache.kafka.clients.admin.<a href="org/apache/kafka/clients/admin/PartitionReassignment.html" title="class in org.apache.kafka.clients.admin">PartitionReassignment</a></dt> +<dd> +<div class="block">The brokers that we are adding this partition to as part of a reassignment.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addInt-java.lang.String-int-">addInt(String, int)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addInt-java.lang.String-int-">addInt(String, int)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsMetrics.html#addLatencyAndThroughputSensor-java.lang.String-java.lang.String-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-java.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"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">since 2.5. Use <a href="org/apache/kafka/streams/StreamsMetrics.html#addLatencyRateTotalSensor-java.lang.String-java.lang.String-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-java.lang.String...-"><code>addLatencyRateTotalSensor()</code></a> + instead.</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsMetrics.html#addLatencyRateTotalSensor-java.lang.String-java.lang.String-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-java.lang.String...-">addLatencyRateTotalSensor(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, rate and total sensor for a specific operation, which will include the following metrics: + + average latency + max latency + invocation rate (num.operations / seconds) + total invocation count + + Whenever a user records this sensor via <code>Sensor.record(double)</code> etc, it will be counted as one invocation + of the operation, and hence the rate / count metrics will be updated accordingly; and the recorded latency value + will be used to update the average / max latency as well.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addList-java.lang.String-java.util.List-org.apache.kafka.connect.data.Schema-">addList(String, List<?>, Schema)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addList-java.lang.String-java.util.List-org.apache.kafka.connect.data.Schema-">addList(String, List<?>, Schema)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addLong-java.lang.String-long-">addLong(String, long)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addLong-java.lang.String-long-">addLong(String, long)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addMap-java.lang.String-java.util.Map-org.apache.kafka.connect.data.Schema-">addMap(String, Map<?, ?>, Schema)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addMap-java.lang.String-java.util.Map-org.apache.kafka.connect.data.Schema-">addMap(String, Map<?, ?>, Schema)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addProcessor-java.lang.String-org.apache.kafka.streams.processor.ProcessorSupplier-java.lang.String...-">addProcessor(String, ProcessorSupplier, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/StreamsMetrics.html#addRateTotalSensor-java.lang.String-java.lang.String-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-java.lang.String...-">addRateTotalSensor(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 rate and a total sensor for a specific operation, which will include the following metrics: + + invocation rate (num.operations / time unit) + total invocation count + + Whenever a user records this sensor via <code>Sensor.record(double)</code> etc, + it will be counted as one invocation of the operation, and hence the rate / count metrics will be updated accordingly.</div> +</dd> +<dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/streams/StreamsMetrics.html#addSensor-java.lang.String-org.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="memberNameLink"><a href="org/apache/kafka/streams/StreamsMetrics.html#addSensor-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-org.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="memberNameLink"><a href="org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig-java.util.Map-org.apache.kafka.common.serialization.Serializer-org.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="memberNameLink"><a href="org/apache/kafka/clients/producer/ProducerConfig.html#addSerializerToConfig-java.util.Properties-org.apache.kafka.common.serialization.Serializer-org.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="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addShort-java.lang.String-short-">addShort(String, short)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addShort-java.lang.String-short-">addShort(String, short)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-java.lang.String-java.lang.String...-">addSink(String, String, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-java.lang.String-org.apache.kafka.streams.processor.StreamPartitioner-java.lang.String...-">addSink(String, String, StreamPartitioner<? super K, ? super V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-java.lang.String-org.apache.kafka.common.serialization.Serializer-org.apache.kafka.common.serialization.Serializer-java.lang.String...-">addSink(String, String, Serializer<K>, Serializer<V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-java.lang.String-org.apache.kafka.common.serialization.Serializer-org.apache.kafka.common.serialization.Serializer-org.apache.kafka.streams.processor.StreamPartitioner-java.lang.String...-">addSink(String, String, Serializer<K>, Serializer<V>, StreamPartitioner<? super K, ? super V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-org.apache.kafka.streams.processor.TopicNameExtractor-java.lang.String...-">addSink(String, TopicNameExtractor<K, V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to Kafka topics based on <code>topicExtractor</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-org.apache.kafka.streams.processor.TopicNameExtractor-org.apache.kafka.streams.processor.StreamPartitioner-java.lang.String...-">addSink(String, TopicNameExtractor<K, V>, StreamPartitioner<? super K, ? super V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to Kafka topics based on <code>topicExtractor</code>, + using the supplied partitioner.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-org.apache.kafka.streams.processor.TopicNameExtractor-org.apache.kafka.common.serialization.Serializer-org.apache.kafka.common.serialization.Serializer-java.lang.String...-">addSink(String, TopicNameExtractor<K, V>, Serializer<K>, Serializer<V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to Kafka topics based on <code>topicExtractor</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSink-java.lang.String-org.apache.kafka.streams.processor.TopicNameExtractor-org.apache.kafka.common.serialization.Serializer-org.apache.kafka.common.serialization.Serializer-org.apache.kafka.streams.processor.StreamPartitioner-java.lang.String...-">addSink(String, TopicNameExtractor<K, V>, Serializer<K>, Serializer<V>, StreamPartitioner<? super K, ? super V>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</a></dt> +<dd> +<div class="block">Add a new sink that forwards records from upstream parent processor and/or source nodes to Kafka topics based on <code>topicExtractor</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-java.lang.String-java.lang.String...-">addSource(String, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-java.lang.String-java.util.regex.Pattern-">addSource(String, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-java.lang.String-java.lang.String...-">addSource(Topology.AutoOffsetReset, String, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-java.lang.String-java.util.regex.Pattern-">addSource(Topology.AutoOffsetReset, String, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.processor.TimestampExtractor-java.lang.String-java.lang.String...-">addSource(TimestampExtractor, String, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.processor.TimestampExtractor-java.lang.String-java.util.regex.Pattern-">addSource(TimestampExtractor, String, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-org.apache.kafka.streams.processor.TimestampExtractor-java.lang.String-java.lang.String...-">addSource(Topology.AutoOffsetReset, TimestampExtractor, String, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-org.apache.kafka.streams.processor.TimestampExtractor-java.lang.String-java.util.regex.Pattern-">addSource(Topology.AutoOffsetReset, TimestampExtractor, String, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-java.lang.String-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.lang.String...-">addSource(String, Deserializer<?>, Deserializer<?>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-java.lang.String-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.util.regex.Pattern-">addSource(String, Deserializer<?>, Deserializer<?>, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-java.lang.String-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.lang.String...-">addSource(Topology.AutoOffsetReset, String, Deserializer<?>, Deserializer<?>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-java.lang.String-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.util.regex.Pattern-">addSource(Topology.AutoOffsetReset, String, Deserializer<?>, Deserializer<?>, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-java.lang.String-org.apache.kafka.streams.processor.TimestampExtractor-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.lang.String...-">addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer<?>, Deserializer<?>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addSource-org.apache.kafka.streams.Topology.AutoOffsetReset-java.lang.String-org.apache.kafka.streams.processor.TimestampExtractor-org.apache.kafka.common.serialization.Deserializer-org.apache.kafka.common.serialization.Deserializer-java.util.regex.Pattern-">addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer<?>, Deserializer<?>, Pattern)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</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="memberNameLink"><a href="org/apache/kafka/streams/StreamsBuilder.html#addStateStore-org.apache.kafka.streams.state.StoreBuilder-">addStateStore(StoreBuilder<?>)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/StreamsBuilder.html" title="class in org.apache.kafka.streams">StreamsBuilder</a></dt> +<dd> +<div class="block">Adds a state store to the underlying <a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams"><code>Topology</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/Topology.html#addStateStore-org.apache.kafka.streams.state.StoreBuilder-java.lang.String...-">addStateStore(StoreBuilder<?>, String...)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/Topology.html" title="class in org.apache.kafka.streams">Topology</a></dt> +<dd> +<div class="block">Adds a state store.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addString-java.lang.String-java.lang.String-">addString(String, String)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addString-java.lang.String-java.lang.String-">addString(String, String)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addStruct-java.lang.String-org.apache.kafka.connect.data.Struct-">addStruct(String, Struct)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addStruct-java.lang.String-org.apache.kafka.connect.data.Struct-">addStruct(String, Struct)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsMetrics.html#addThroughputSensor-java.lang.String-java.lang.String-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-java.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"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">since 2.5. Use <a href="org/apache/kafka/streams/StreamsMetrics.html#addRateTotalSensor-java.lang.String-java.lang.String-java.lang.String-org.apache.kafka.common.metrics.Sensor.RecordingLevel-java.lang.String...-"><code>addRateTotalSensor()</code></a> instead.</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addTime-java.lang.String-java.util.Date-">addTime(String, Date)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addTime-java.lang.String-java.util.Date-">addTime(String, Date)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and <a href="org/apache/kafka/connect/data/Time.html" title="class in org.apache.kafka.connect.data"><code>Time</code></a> value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addTimestamp-java.lang.String-java.util.Date-">addTimestamp(String, Date)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/header/Headers.html#addTimestamp-java.lang.String-java.util.Date-">addTimestamp(String, Date)</a></span> - Method in interface org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/Headers.html" title="interface in org.apache.kafka.connect.header">Headers</a></dt> +<dd> +<div class="block">Add to this collection a <a href="org/apache/kafka/connect/header/Header.html" title="interface in org.apache.kafka.connect.header"><code>Header</code></a> with the given key and <a href="org/apache/kafka/connect/data/Timestamp.html" title="class in org.apache.kafka.connect.data"><code>Timestamp</code></a> value.</div> +</dd> +<dt><span class="memberNameLink"><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><span class="memberNameLink"><a href="org/apache/kafka/connect/header/ConnectHeaders.html#addWithoutValidating-java.lang.String-java.lang.Object-org.apache.kafka.connect.data.Schema-">addWithoutValidating(String, Object, Schema)</a></span> - Method in class org.apache.kafka.connect.header.<a href="org/apache/kafka/connect/header/ConnectHeaders.html" title="class in org.apache.kafka.connect.header">ConnectHeaders</a></dt> +<dd> </dd> +<dt><a href="org/apache/kafka/clients/admin/Admin.html" title="interface in org.apache.kafka.clients.admin"><span class="typeNameLink">Admin</span></a> - Interface 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="memberNameLink"><a href="org/apache/kafka/connect/mirror/MirrorClientConfig.html#ADMIN_CLIENT_PREFIX">ADMIN_CLIENT_PREFIX</a></span> - Static variable in class org.apache.kafka.connect.mirror.<a href="org/apache/kafka/connect/mirror/MirrorClientConfig.html" title="class in org.apache.kafka.connect.mirror">MirrorClientConfig</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsConfig.html#ADMIN_CLIENT_PREFIX">ADMIN_CLIENT_PREFIX</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">Prefix used to isolate <a href="org/apache/kafka/clients/admin/Admin.html" title="interface in org.apache.kafka.clients.admin"><code>admin</code></a> configs from other client configs.</div> +</dd> +<dt><a href="org/apache/kafka/clients/admin/AdminClient.html" title="class in org.apache.kafka.clients.admin"><span class="typeNameLink">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 base class for in-built admin clients.</div> +</dd> +<dt><span class="memberNameLink"><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="typeNameLink">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="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/clients/admin/AdminClientConfig.html#AdminClientConfig-java.util.Map-boolean-">AdminClientConfig(Map<?, ?>, boolean)</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="memberNameLink"><a href="org/apache/kafka/streams/processor/ThreadMetadata.html#adminClientId--">adminClientId()</a></span> - Method in class org.apache.kafka.streams.processor.<a href="org/apache/kafka/streams/processor/ThreadMetadata.html" title="class in org.apache.kafka.streams.processor">ThreadMetadata</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/StreamsConfig.html#adminClientPrefix-java.lang.String-">adminClientPrefix(String)</a></span> - Static method 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">Prefix a property with <a href="org/apache/kafka/streams/StreamsConfig.html#ADMIN_CLIENT_PREFIX"><code>StreamsConfig.ADMIN_CLIENT_PREFIX</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/connect/mirror/MirrorClientConfig.html#adminConfig--">adminConfig()</a></span> - Method in class org.apache.kafka.connect.mirror.<a href="org/apache/kafka/connect/mirror/MirrorClientConfig.html" title="class in org.apache.kafka.connect.mirror">MirrorClientConfig</a></dt> +<dd> +<div class="block">Sub-config for Admin clients.</div> +</dd> +<dt><span class="memberNameLink"><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"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Use <a href="org/apache/kafka/streams/kstream/TimeWindows.html#advanceBy-java.time.Duration-"><code>TimeWindows.advanceBy(Duration)</code></a> instead</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/kstream/TimeWindows.html#advanceBy-java.time.Duration-">advanceBy(Duration)</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="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/streams/TestInputTopic.html#advanceTime-java.time.Duration-">advanceTime(Duration)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/TestInputTopic.html" title="class in org.apache.kafka.streams">TestInputTopic</a></dt> +<dd> +<div class="block">Advances the internally tracked event time of this input topic.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/test/ConsumerRecordFactory.html#advanceTimeMs-long-">advanceTimeMs(long)</a></span> - Method in class org.apache.kafka.streams.test.<a href="org/apache/kafka/streams/test/ConsumerRecordFactory.html" title="class in org.apache.kafka.streams.test">ConsumerRecordFactory</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span></div> +<div class="block">Advances the internally tracked time.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/TopologyTestDriver.html#advanceWallClockTime-long-">advanceWallClockTime(long)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/TopologyTestDriver.html" title="class in org.apache.kafka.streams">TopologyTestDriver</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Since 2.4 use <a href="org/apache/kafka/streams/TopologyTestDriver.html#advanceWallClockTime-java.time.Duration-"><code>TopologyTestDriver.advanceWallClockTime(Duration)</code></a> instead</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/TopologyTestDriver.html#advanceWallClockTime-java.time.Duration-">advanceWallClockTime(Duration)</a></span> - Method in class org.apache.kafka.streams.<a href="org/apache/kafka/streams/TopologyTestDriver.html" title="class in org.apache.kafka.streams">TopologyTestDriver</a></dt> +<dd> +<div class="block">Advances the internally mocked wall-clock time.</div> +</dd> +<dt><span class="memberNameLink"><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"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Use <a href="org/apache/kafka/streams/kstream/JoinWindows.html#after-java.time.Duration-"><code>JoinWindows.after(Duration)</code></a> instead</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/kstream/JoinWindows.html#after-java.time.Duration-">after(Duration)</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>timeDifference</code> but keep the start window boundary as is.</div> +</dd> +<dt><span class="memberNameLink"><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="memberNameLink"><a href="org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-">aggregate(Initializer<VOut>)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="org/apache/kafka/streams/kstream/CogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">CogroupedKStream</a></dt> +<dd> +<div class="block">Aggregate the values of records in these streams by the grouped key.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Named-">aggregate(Initializer<VOut>, Named)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="org/apache/kafka/streams/kstream/CogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">CogroupedKStream</a></dt> +<dd> +<div class="block">Aggregate the values of records in these streams by the grouped key.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Materialized-">aggregate(Initializer<VOut>, Materialized<K, VOut, KeyValueStore<Bytes, byte[]>>)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="org/apache/kafka/streams/kstream/CogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">CogroupedKStream</a></dt> +<dd> +<div class="block">Aggregate the values of records in these streams by the grouped key.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/kstream/CogroupedKStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-">aggregate(Initializer<VOut>, Named, Materialized<K, VOut, KeyValueStore<Bytes, byte[]>>)</a></span> - Method in interface org.apache.kafka.streams.kstream.<a href="org/apache/kafka/streams/kstream/CogroupedKStream.html" title="interface in org.apache.kafka.streams.kstream">CogroupedKStream</a></dt> +<dd> +<div class="block">Aggregate the values of records in these streams by the grouped key.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/kafka/streams/kstream/KGroupedStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-">aggregate(Initializer<VR>, Aggregator<? super K, ? super V, 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="memberNameLink"><a href="org/apache/kafka/streams/kstream/KGroupedStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Materialized-">aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Materialized<K, VR, KeyValueStore<Bytes, byte[]>>)</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="memberNameLink"><a href="org/apache/kafka/streams/kstream/KGroupedStream.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Named-org.apache.kafka.streams.kstream.Materialized-">aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Named, Materialized<K, VR, KeyValueStore<Bytes, byte[]>>)</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="memberNameLink"><a href="org/apache/kafka/streams/kstream/KGroupedTable.html#aggregate-org.apache.kafka.streams.kstream.Initializer-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Aggregator-org.apache.kafka.streams.kstream.Materialized-">aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, Materialized<K, VR, KeyValueStore<Bytes, byte[]>>)</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>
[... 14478 lines stripped ...]
