A B C D E F G H I J K L M N O P Q R S T U V W Z

A

abort() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule

abort() - Method in class org.apache.kafka.common.security.plain.PlainLoginModule

abort() - Method in class org.apache.kafka.common.security.scram.ScramLoginModule

abortTransaction(AbortTransactionSpec) - Method in interface org.apache.kafka.clients.admin.Admin

Forcefully abort a transaction which is open on a topic partition.

abortTransaction(AbortTransactionSpec, AbortTransactionOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Forcefully abort a transaction which is open on a topic partition.

abortTransaction(AbortTransactionSpec, AbortTransactionOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

abortTransaction() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Aborts the ongoing transaction.

abortTransaction() - Method in class org.apache.kafka.clients.producer.MockProducer

abortTransaction() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.abortTransaction()

abortTransactionException - Variable in class org.apache.kafka.clients.producer.MockProducer

AbortTransactionOptions - Class in org.apache.kafka.clients.admin

AbortTransactionOptions() - Constructor for class org.apache.kafka.clients.admin.AbortTransactionOptions

AbortTransactionResult - Class in org.apache.kafka.clients.admin

The result of Admin.abortTransaction(AbortTransactionSpec, AbortTransactionOptions).

AbortTransactionSpec - Class in org.apache.kafka.clients.admin

AbortTransactionSpec(TopicPartition, long, short, int) - Constructor for class org.apache.kafka.clients.admin.AbortTransactionSpec

AbstractConfig - Class in org.apache.kafka.common.config

A convenient base class for configurations to extend.

AbstractConfig(ConfigDef, Map<?, ?>, Map<String, ?>, boolean) - Constructor for class org.apache.kafka.common.config.AbstractConfig

Construct a configuration with a ConfigDef and the configuration properties, which can include properties for zero or more ConfigProvider that will be used to resolve variables in configuration property values.

AbstractConfig(ConfigDef, Map<?, ?>) - Constructor for class org.apache.kafka.common.config.AbstractConfig

Construct a configuration with a ConfigDef and the configuration properties, which can include properties for zero or more ConfigProvider that will be used to resolve variables in configuration property values.

AbstractConfig(ConfigDef, Map<?, ?>, boolean) - Constructor for class org.apache.kafka.common.config.AbstractConfig

Construct a configuration with a ConfigDef and the configuration properties, which can include properties for zero or more ConfigProvider that will be used to resolve variables in configuration property values.

AbstractOptions<T extends AbstractOptions> - Class in org.apache.kafka.clients.admin

AbstractOptions() - Constructor for class org.apache.kafka.clients.admin.AbstractOptions

accept(A, B) - Method in interface org.apache.kafka.common.KafkaFuture.BiConsumer

acceptable(double) - Method in class org.apache.kafka.common.metrics.Quota

AccessControlEntry - Class in org.apache.kafka.common.acl

Represents an access control entry.

AccessControlEntry(String, String, AclOperation, AclPermissionType) - Constructor for class org.apache.kafka.common.acl.AccessControlEntry

Create an instance of an access control entry with the provided parameters.

AccessControlEntry(String, String, AclOperation, AclPermissionType, Collection<Uuid>) - Constructor for class org.apache.kafka.common.acl.AccessControlEntry

Create an instance of an access control entry with the provided parameters.

AccessControlEntryFilter - Class in org.apache.kafka.common.acl

Represents a filter which matches access control entries.

AccessControlEntryFilter(String, String, AclOperation, AclPermissionType) - Constructor for class org.apache.kafka.common.acl.AccessControlEntryFilter

Create an instance of an access control entry filter with the provided parameters.

AccessControlEntryFilter(String, String, AclOperation, AclPermissionType, Collection<Uuid>) - Constructor for class org.apache.kafka.common.acl.AccessControlEntryFilter

Create an instance of an access control entry filter with the provided parameters.

AccessTokenRetriever - Interface in org.apache.kafka.common.security.oauthbearer.secured

An AccessTokenRetriever is the internal API by which the login module will retrieve an access token for use in authorization by the broker.

AccessTokenRetrieverFactory - Class in org.apache.kafka.common.security.oauthbearer.secured

AccessTokenRetrieverFactory() - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenRetrieverFactory

AccessTokenValidator - Interface in org.apache.kafka.common.security.oauthbearer.secured

An instance of AccessTokenValidator acts as a function object that, given an access token in base-64 encoded JWT format, can parse the data, perform validation, and construct an OAuthBearerToken for use by the caller.

AccessTokenValidatorFactory - Class in org.apache.kafka.common.security.oauthbearer.secured

AccessTokenValidatorFactory() - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenValidatorFactory

ACKS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

acks

AclBinding - Class in org.apache.kafka.common.acl

Represents a binding between a resource pattern and an access control entry.

AclBinding(ResourcePattern, AccessControlEntry) - Constructor for class org.apache.kafka.common.acl.AclBinding

Create an instance of this class with the provided parameters.

aclBinding() - Method in class org.apache.kafka.server.authorizer.AclDeleteResult.AclBindingDeleteResult

Returns ACL binding that matched the delete filter.

AclBindingDeleteResult(AclBinding) - Constructor for class org.apache.kafka.server.authorizer.AclDeleteResult.AclBindingDeleteResult

AclBindingDeleteResult(AclBinding, ApiException) - Constructor for class org.apache.kafka.server.authorizer.AclDeleteResult.AclBindingDeleteResult

aclBindingDeleteResults() - Method in class org.apache.kafka.server.authorizer.AclDeleteResult

Returns delete result for each matching ACL binding.

AclBindingFilter - Class in org.apache.kafka.common.acl

A filter which can match AclBinding objects.

AclBindingFilter(ResourcePatternFilter, AccessControlEntryFilter) - Constructor for class org.apache.kafka.common.acl.AclBindingFilter

Create an instance of this filter with the provided parameters.

aclCount() - Method in interface org.apache.kafka.server.authorizer.Authorizer

Get the current number of ACLs, for the purpose of metrics.

AclCreateResult - Class in org.apache.kafka.server.authorizer

AclCreateResult(ApiException) - Constructor for class org.apache.kafka.server.authorizer.AclCreateResult

AclDeleteResult - Class in org.apache.kafka.server.authorizer

AclDeleteResult(ApiException) - Constructor for class org.apache.kafka.server.authorizer.AclDeleteResult

AclDeleteResult(Collection<AclDeleteResult.AclBindingDeleteResult>) - Constructor for class org.apache.kafka.server.authorizer.AclDeleteResult

AclDeleteResult.AclBindingDeleteResult - Class in org.apache.kafka.server.authorizer

Delete result for each ACL binding that matched a delete filter.

AclOperation - Enum in org.apache.kafka.common.acl

Represents an operation which an ACL grants or denies permission to perform.

AclPermissionType - Enum in org.apache.kafka.common.acl

Represents whether an ACL grants or denies permissions.

acls(AclBindingFilter) - Method in interface org.apache.kafka.server.authorizer.Authorizer

Returns ACL bindings which match the provided filter.

Action - Class in org.apache.kafka.server.authorizer

Action(AclOperation, ResourcePattern, int, boolean, boolean) - Constructor for class org.apache.kafka.server.authorizer.Action

activeProducers() - Method in class org.apache.kafka.clients.admin.DescribeProducersResult.PartitionProducerState

add(Header) - Method in interface org.apache.kafka.common.header.Headers

Adds a header (key inside), to the end, returning if the operation succeeded.

add(String, byte[]) - Method in interface org.apache.kafka.common.header.Headers

Creates and adds a header, to the end, returning if the operation succeeded.

add(CompoundStat) - Method in class org.apache.kafka.common.metrics.Sensor

Register a compound statistic with this sensor with no config override

add(CompoundStat, MetricConfig) - Method in class org.apache.kafka.common.metrics.Sensor

Register a compound statistic with this sensor which yields multiple measurable quantities (like a histogram)

add(MetricName, MeasurableStat) - Method in class org.apache.kafka.common.metrics.Sensor

Register a metric with this sensor

add(MetricName, MeasurableStat, MetricConfig) - Method in class org.apache.kafka.common.metrics.Sensor

Register a metric with this sensor

addClientSaslSupport(ConfigDef) - Static method in class org.apache.kafka.common.config.SaslConfigs

addClientSslSupport(ConfigDef) - Static method in class org.apache.kafka.common.config.SslConfigs

addErrorMessage(String) - Method in class org.apache.kafka.common.config.ConfigValue

addingReplicas() - Method in class org.apache.kafka.clients.admin.PartitionReassignment

The brokers that we are adding this partition to as part of a reassignment.

additionError() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

An optional error that gives context as to why the operation is in the given status.

addMetric(MetricName, Measurable) - Method in class org.apache.kafka.common.metrics.Metrics

Add a metric to monitor an object that implements measurable.

addMetric(MetricName, MetricConfig, Measurable) - Method in class org.apache.kafka.common.metrics.Metrics

Add a metric to monitor an object that implements Measurable.

addMetric(MetricName, MetricConfig, MetricValueProvider<?>) - Method in class org.apache.kafka.common.metrics.Metrics

Add a metric to monitor an object that implements MetricValueProvider.

addMetric(MetricName, MetricValueProvider<?>) - Method in class org.apache.kafka.common.metrics.Metrics

Add a metric to monitor an object that implements MetricValueProvider.

addMetricIfAbsent(MetricName, MetricConfig, MetricValueProvider<?>) - Method in class org.apache.kafka.common.metrics.Metrics

Create or get an existing metric to monitor an object that implements MetricValueProvider.

addRecord(ConsumerRecord<K, V>) - Method in class org.apache.kafka.clients.consumer.MockConsumer

addReporter(MetricsReporter) - Method in class org.apache.kafka.common.metrics.Metrics

Add a MetricReporter

Admin - Interface in org.apache.kafka.clients.admin

The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs.

AdminClient - Class in org.apache.kafka.clients.admin

The base class for in-built admin clients.

AdminClient() - Constructor for class org.apache.kafka.clients.admin.AdminClient

AdminClientConfig - Class in org.apache.kafka.clients.admin

The AdminClient configuration class, which also contains constants for configuration entry names.

AdminClientConfig(Map<?, ?>) - Constructor for class org.apache.kafka.clients.admin.AdminClientConfig

AdminClientConfig(Map<?, ?>, boolean) - Constructor for class org.apache.kafka.clients.admin.AdminClientConfig

all() - Method in class org.apache.kafka.clients.admin.AbortTransactionResult

Get a future which completes when the transaction specified by AbortTransactionSpec in the respective call to Admin.abortTransaction(AbortTransactionSpec, AbortTransactionOptions) returns successfully or fails due to an error or timeout.

all() - Method in class org.apache.kafka.clients.admin.AlterClientQuotasResult

Returns a future which succeeds only if all quota alterations succeed.

all() - Method in class org.apache.kafka.clients.admin.AlterConfigsResult

Return a future which succeeds only if all the alter configs operations succeed.

all() - Method in class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult

Return a future which succeeds if all the alter offsets succeed.

all() - Method in class org.apache.kafka.clients.admin.AlterLeadershipPriorityResult

Return a future which succeeds only if all the leadership priority changes succeed.

all() - Method in class org.apache.kafka.clients.admin.AlterMirrorsResult

Returns a future which succeeds only if all mirror alter operations succeed.

all() - Method in class org.apache.kafka.clients.admin.AlterPartitionReassignmentsResult

Return a future which succeeds only if all the reassignments were successfully initiated.

all() - Method in class org.apache.kafka.clients.admin.AlterReplicaLogDirsResult

Return a KafkaFuture which succeeds on KafkaFuture.get() if all the replica movement have succeeded.

all() - Method in class org.apache.kafka.clients.admin.AlterUserScramCredentialsResult

Return a future which succeeds only if all the user SCRAM credential alterations succeed.

all() - Method in class org.apache.kafka.clients.admin.CreateAclsResult

Return a future which succeeds only if all the ACL creations succeed.

all() - Method in class org.apache.kafka.clients.admin.CreateClusterLinksResult

Returns a future which succeeds only if all cluster link creation requests succeed.

all() - Method in class org.apache.kafka.clients.admin.CreatePartitionsResult

Return a future which succeeds if all the partition creations succeed.

all() - Method in class org.apache.kafka.clients.admin.CreateTopicsResult

Return a future which succeeds if all the topic creations succeed.

all() - Method in class org.apache.kafka.clients.admin.DeleteAclsResult

Return a future which succeeds only if all the ACLs deletions succeed, and which contains all the deleted ACLs.

all() - Method in class org.apache.kafka.clients.admin.DeleteClusterLinksResult

Returns a future which succeeds only if all cluster link deletion requests succeed.

all() - Method in class org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsResult

Return a future which succeeds only if all the deletions succeed.

all() - Method in class org.apache.kafka.clients.admin.DeleteConsumerGroupsResult

Return a future which succeeds only if all the consumer group deletions succeed.

all() - Method in class org.apache.kafka.clients.admin.DeleteRecordsResult

Return a future which succeeds only if all the records deletions succeed.

all() - Method in class org.apache.kafka.clients.admin.DeleteTopicsResult

all() - Method in class org.apache.kafka.clients.admin.DescribeConfigsResult

Return a future which succeeds only if all the config descriptions succeed.

all() - Method in class org.apache.kafka.clients.admin.DescribeConsumerGroupsResult

Return a future which yields all ConsumerGroupDescription objects, if all the describes succeed.

all() - Method in class org.apache.kafka.clients.admin.DescribeLogDirsResult

Deprecated.

Deprecated Since Kafka 2.7. Use DescribeLogDirsResult.allDescriptions().

all() - Method in class org.apache.kafka.clients.admin.DescribeMirrorsResult

Returns a future which succeeds only if all describe mirrors requests succeed.

all() - Method in class org.apache.kafka.clients.admin.DescribeProducersResult

all() - Method in class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult

Return a future which succeeds if log directory information of all replicas are available

all() - Method in class org.apache.kafka.clients.admin.DescribeTopicsResult

Deprecated.

Since 3.1.0 use DescribeTopicsResult.allTopicNames() instead

all() - Method in class org.apache.kafka.clients.admin.DescribeTransactionsResult

Get a future which returns a map of the transaction descriptions requested in the respective call to Admin.describeTransactions(Collection, DescribeTransactionsOptions).

all() - Method in class org.apache.kafka.clients.admin.DescribeUserScramCredentialsResult

all() - Method in class org.apache.kafka.clients.admin.ElectLeadersResult

Return a future which succeeds if all the topic elections succeed.

all() - Method in class org.apache.kafka.clients.admin.FenceProducersResult

Return a future which succeeds only if all the producer fencings succeed.

all() - Method in class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult

Return a future which yields all Map objects, if requests for all the groups succeed.

all() - Method in class org.apache.kafka.clients.admin.ListConsumerGroupsResult

Returns a future that yields either an exception, or the full set of consumer group listings.

all() - Method in class org.apache.kafka.clients.admin.ListOffsetsResult

Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.

all() - Method in class org.apache.kafka.clients.admin.ListTransactionsResult

Get all transaction listings.

all() - Method in class org.apache.kafka.clients.admin.RemoveBrokersResult

Return a future which succeeds only if all the broker removal operations succeed.

all() - Method in class org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult

Returns a future which indicates whether the request was 100% success, i.e.

all() - Method in class org.apache.kafka.clients.admin.ReplicaStatusResult

Returns a future which succeeds only if all replica status requests succeed.

all() - Method in class org.apache.kafka.clients.admin.UnregisterBrokerResult

Return a future which succeeds if the operation is successful.

all() - Method in class org.apache.kafka.clients.admin.UpdateFeaturesResult

Return a future which succeeds if all the feature updates succeed.

all() - Static method in class org.apache.kafka.common.quota.ClientQuotaFilter

Constructs and returns a quota filter that matches all configured entities.

allByBrokerId() - Method in class org.apache.kafka.clients.admin.ListTransactionsResult

Get all transaction listings in a map which is keyed by the ID of respective broker that is currently managing them.

allDescriptions() - Method in class org.apache.kafka.clients.admin.DescribeLogDirsResult

Return a future which succeeds only if all the brokers have responded without error.

allOf(KafkaFuture<?>...) - Static method in class org.apache.kafka.common.KafkaFuture

Returns a new KafkaFuture that is completed when all the given futures have completed.

ALLOW_AUTO_CREATE_TOPICS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

allow.auto.create.topics

allowDowngrade() - Method in class org.apache.kafka.clients.admin.FeatureUpdate

Deprecated.

allResults() - Method in class org.apache.kafka.clients.admin.ReplicaStatusResult

Return a feature that succeeds when all replica status requests have succeed.

allTopicIds() - Method in class org.apache.kafka.clients.admin.DescribeTopicsResult

allTopicNames() - Method in class org.apache.kafka.clients.admin.DescribeTopicsResult

alterBrokerReplicaExclusions(Map<Integer, ExclusionOp>, AlterBrokerReplicaExclusionsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Alters the broker replica exclusions in the cluster.

alterBrokerReplicaExclusions(Map<Integer, ExclusionOp>) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Alters the broker replica exclusions in the cluster.

alterBrokerReplicaExclusions(Map<Integer, ExclusionOp>, AlterBrokerReplicaExclusionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterBrokerReplicaExclusionsOptions - Class in org.apache.kafka.clients.admin

AlterBrokerReplicaExclusionsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterBrokerReplicaExclusionsOptions

AlterBrokerReplicaExclusionsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.alterBrokerReplicaExclusions(Map, AlterBrokerReplicaExclusionsOptions).

AlterBrokerReplicaExclusionsResult.ExclusionsResult - Class in org.apache.kafka.clients.admin

alterClientQuotas(Collection<ClientQuotaAlteration>) - Method in interface org.apache.kafka.clients.admin.Admin

Alters client quota configurations with the specified alterations.

alterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Alters client quota configurations with the specified alterations.

alterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterClientQuotasOptions - Class in org.apache.kafka.clients.admin

Options for Admin.alterClientQuotas(Collection, AlterClientQuotasOptions).

AlterClientQuotasOptions() - Constructor for class org.apache.kafka.clients.admin.AlterClientQuotasOptions

AlterClientQuotasResult - Class in org.apache.kafka.clients.admin

The result of the Admin.alterClientQuotas(Collection, AlterClientQuotasOptions) call.

AlterClientQuotasResult(Map<ClientQuotaEntity, KafkaFuture<Void>>) - Constructor for class org.apache.kafka.clients.admin.AlterClientQuotasResult

Maps an entity to its alteration result.

AlterConfigOp - Class in org.apache.kafka.clients.admin

A class representing a alter configuration entry containing name, value and operation type.

AlterConfigOp(ConfigEntry, AlterConfigOp.OpType) - Constructor for class org.apache.kafka.clients.admin.AlterConfigOp

AlterConfigOp.OpType - Enum in org.apache.kafka.clients.admin

AlterConfigPolicy - Interface in org.apache.kafka.server.policy

An interface for enforcing a policy on alter configs requests.

AlterConfigPolicy.RequestMetadata - Class in org.apache.kafka.server.policy

Class containing the create request parameters.

alterConfigs(Map<ConfigResource, Config>) - Method in interface org.apache.kafka.clients.admin.Admin

Deprecated.

Since 2.3. Use Admin.incrementalAlterConfigs(Map).

alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Deprecated.

Since 2.3. Use Admin.incrementalAlterConfigs(Map, AlterConfigsOptions).

alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

Deprecated.

AlterConfigsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.incrementalAlterConfigs(Map) and Admin.alterConfigs(Map).

AlterConfigsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterConfigsOptions

AlterConfigsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.alterConfigs(Map) call.

alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>) - Method in interface org.apache.kafka.clients.admin.Admin

Alters offsets for the specified group.

alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Alters offsets for the specified group.

alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterConsumerGroupOffsetsOptions - Class in org.apache.kafka.clients.admin

Options for the Admin.alterConsumerGroupOffsets(String, Map, AlterConsumerGroupOffsetsOptions) call.

AlterConsumerGroupOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions

AlterConsumerGroupOffsetsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.alterConsumerGroupOffsets(String, Map) call.

alterLeadershipPriority(AlterLeadershipPrioritySpec, AlterLeadershipPriorityOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Change broker leadership priority by promoting / demoting a list of brokerIds for a given reason.

alterLeadershipPriority(AlterLeadershipPrioritySpec, AlterLeadershipPriorityOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterLeadershipPriorityOptions - Class in org.apache.kafka.clients.admin

AlterLeadershipPriorityOptions() - Constructor for class org.apache.kafka.clients.admin.AlterLeadershipPriorityOptions

AlterLeadershipPriorityResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.alterLeadershipPriority(AlterLeadershipPrioritySpec, AlterLeadershipPriorityOptions) .

AlterLeadershipPrioritySpec - Class in org.apache.kafka.clients.admin

AlterLeadershipPrioritySpec(Set<Integer>, AlterLeadershipPrioritySpec.PriorityOperationEnum, String) - Constructor for class org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec

AlterLeadershipPrioritySpec(Set<Integer>, AlterLeadershipPrioritySpec.PriorityOperationEnum, String, boolean) - Constructor for class org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec

AlterLeadershipPrioritySpec.PriorityOperationEnum - Enum in org.apache.kafka.clients.admin

AlterMirrorOp - Enum in org.apache.kafka.clients.admin

A class representing an alter mirror operation.

alterMirrors(Map<String, AlterMirrorOp>, AlterMirrorsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Performs a state alteration for topic mirroring.

alterMirrors(Map<String, AlterMirrorOp>, AlterMirrorsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterMirrorsOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin#alterMirrors(List, AlterMirrorsOptions).

AlterMirrorsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterMirrorsOptions

AlterMirrorsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.alterMirrors(Map, AlterMirrorsOptions).

AlterMirrorsResult(Map<String, KafkaFuture<Void>>) - Constructor for class org.apache.kafka.clients.admin.AlterMirrorsResult

alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>) - Method in interface org.apache.kafka.clients.admin.Admin

Change the reassignments for one or more partitions.

alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Change the reassignments for one or more partitions.

alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterPartitionReassignmentsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions) The API of this class is evolving.

AlterPartitionReassignmentsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions

AlterPartitionReassignmentsResult - Class in org.apache.kafka.clients.admin

The result of Admin.alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions).

alterReplicaLogDirs(Map<TopicPartitionReplica, String>) - Method in interface org.apache.kafka.clients.admin.Admin

Change the log directory for the specified replicas.

alterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Change the log directory for the specified replicas.

alterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterReplicaLogDirsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions).

AlterReplicaLogDirsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions

AlterReplicaLogDirsResult - Class in org.apache.kafka.clients.admin

The result of Admin.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions).

alterUserScramCredentials(List<UserScramCredentialAlteration>) - Method in interface org.apache.kafka.clients.admin.Admin

Alter SASL/SCRAM credentials for the given users.

alterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Alter SASL/SCRAM credentials.

alterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

AlterUserScramCredentialsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.alterUserScramCredentials(List, AlterUserScramCredentialsOptions) The API of this class is evolving.

AlterUserScramCredentialsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions

AlterUserScramCredentialsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.alterUserScramCredentials(List) call.

AlterUserScramCredentialsResult(Map<String, KafkaFuture<Void>>) - Constructor for class org.apache.kafka.clients.admin.AlterUserScramCredentialsResult

ANONYMOUS - Static variable in class org.apache.kafka.common.security.auth.KafkaPrincipal

ANY - Static variable in class org.apache.kafka.common.acl.AccessControlEntryFilter

Matches any access control entry.

ANY - Static variable in class org.apache.kafka.common.acl.AclBindingFilter

A filter which matches any ACL binding.

ANY - Static variable in class org.apache.kafka.common.resource.ResourcePatternFilter

Matches any resource pattern.

ApiException - Exception in org.apache.kafka.common.errors

Any API exception that is part of the public protocol and should be a subclass of this class and be part of this package.

ApiException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ApiException

ApiException(String) - Constructor for exception org.apache.kafka.common.errors.ApiException

ApiException(Throwable) - Constructor for exception org.apache.kafka.common.errors.ApiException

ApiException() - Constructor for exception org.apache.kafka.common.errors.ApiException

APPEND_RECORD_INTERCEPTOR_CLASSES_CONFIG - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

APPEND_RECORD_INTERCEPTOR_CLASSES_CONFIG_DOC - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

appendDeserializerToConfig(Map<String, Object>, Deserializer<?>, Deserializer<?>) - Static method in class org.apache.kafka.clients.consumer.ConsumerConfig

apply(A) - Method in interface org.apache.kafka.common.KafkaFuture.BaseFunction

assign(Collection<TopicPartition>) - Method in interface org.apache.kafka.clients.consumer.Consumer

assign(Cluster, ConsumerPartitionAssignor.GroupSubscription) - Method in interface org.apache.kafka.clients.consumer.ConsumerPartitionAssignor

Perform the group assignment given the member subscriptions and current cluster metadata.

assign(Map<String, Integer>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.apache.kafka.clients.consumer.CooperativeStickyAssignor

assign(Collection<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Manually assign a list of partitions to this consumer.

assign(Collection<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.MockConsumer

assign(Map<String, Integer>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.apache.kafka.clients.consumer.RangeAssignor

assign(Map<String, Integer>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.apache.kafka.clients.consumer.RoundRobinAssignor

ASSIGN_FROM_SUBSCRIBED_ASSIGNORS - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

assignment() - Method in class org.apache.kafka.clients.admin.MemberDescription

The assignment of the group member.

assignment() - Method in interface org.apache.kafka.clients.consumer.Consumer

Assignment(List<TopicPartition>, ByteBuffer) - Constructor for class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Assignment

Assignment(List<TopicPartition>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Assignment

assignment() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the set of partitions currently assigned to this consumer.

assignment() - Method in class org.apache.kafka.clients.consumer.MockConsumer

assignments() - Method in class org.apache.kafka.clients.admin.NewPartitions

The replica assignments for the new partitions, or null if the assignment will be done by the controller.

atLeast(Number) - Static method in class org.apache.kafka.common.config.ConfigDef.Range

A numeric range that checks only the lower bound

atMostOfSize(int) - Static method in class org.apache.kafka.common.config.ConfigDef.ListSize

AuthenticateCallbackHandler - Interface in org.apache.kafka.common.security.auth

authenticated() - Method in class org.apache.kafka.common.security.plain.PlainAuthenticateCallback

Returns true if client password matches expected password, false otherwise.

authenticated(boolean) - Method in class org.apache.kafka.common.security.plain.PlainAuthenticateCallback

Sets the authenticated state.

AuthenticationContext - Interface in org.apache.kafka.common.security.auth

An object representing contextual information from the authentication session.

AuthenticationException - Exception in org.apache.kafka.common.errors

This exception indicates that SASL authentication has failed.

AuthenticationException(String) - Constructor for exception org.apache.kafka.common.errors.AuthenticationException

AuthenticationException(Throwable) - Constructor for exception org.apache.kafka.common.errors.AuthenticationException

AuthenticationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.AuthenticationException

AuthenticationException(String, AuthenticationErrorInfo) - Constructor for exception org.apache.kafka.common.errors.AuthenticationException

AuthenticationException(String, Throwable, AuthenticationErrorInfo) - Constructor for exception org.apache.kafka.common.errors.AuthenticationException

authenticationId() - Method in class org.apache.kafka.common.security.auth.ConfluentPrincipal

Returns the public credential (e.g.

AuthenticationTimeoutException - Exception in org.apache.kafka.common.errors

AuthenticationTimeoutException represents that an asynchronous authentication did not execute within its timeout threshold and threw an error.

AuthenticationTimeoutException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.AuthenticationTimeoutException

AuthorizableRequestContext - Interface in org.apache.kafka.server.authorizer

Request context interface that provides data from request header as well as connection and authentication information to plugins.

AUTHORIZATION_HEADER - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.HttpAccessTokenRetriever

AuthorizationException - Exception in org.apache.kafka.common.errors

AuthorizationException(String) - Constructor for exception org.apache.kafka.common.errors.AuthorizationException

AuthorizationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.AuthorizationException

AuthorizationIdProvider - Interface in org.apache.kafka.common.security.auth

AuthorizationResult - Enum in org.apache.kafka.server.authorizer

authorize(AuthorizableRequestContext, List<Action>) - Method in interface org.apache.kafka.server.authorizer.Authorizer

Authorizes the specified action.

authorizeByResourceType(AuthorizableRequestContext, AclOperation, ResourceType) - Method in interface org.apache.kafka.server.authorizer.Authorizer

Check if the caller is authorized to perform the given ACL operation on at least one resource of the given type.

authorizedOperations() - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

authorizedOperations for this group, or null if that information is not known.

authorizedOperations() - Method in class org.apache.kafka.clients.admin.DescribeClusterResult

Returns a future which yields authorized operations.

authorizedOperations() - Method in class org.apache.kafka.clients.admin.TopicDescription

authorized operations for this topic, or null if this is not known.

Authorizer - Interface in org.apache.kafka.server.authorizer

Pluggable authorizer interface for Kafka brokers.

AuthorizerNotReadyException - Exception in org.apache.kafka.common.errors

An exception that indicates that the authorizer is not ready to receive the request yet.

AuthorizerNotReadyException() - Constructor for exception org.apache.kafka.common.errors.AuthorizerNotReadyException

AuthorizerServerInfo - Interface in org.apache.kafka.server.authorizer

Runtime broker configuration metadata provided to authorizers during start up.

AUTO_COMMIT_INTERVAL_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

auto.commit.interval.ms

AUTO_OFFSET_RESET_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

auto.offset.reset

AUTO_OFFSET_RESET_DOC - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

available() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

availablePartitionsForTopic(String) - Method in class org.apache.kafka.common.Cluster

Get the list of available partitions for this topic

Avg - Class in org.apache.kafka.common.metrics.stats

A SampledStat that maintains a simple average over its samples.

Avg() - Constructor for class org.apache.kafka.common.metrics.stats.Avg

avgResources() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStats

Cluster-wide statistics for average resource usages.

B

BalanceCannotBeImprovedException - Exception in org.apache.kafka.common.errors

Thrown when the Confluent Balancer is detecting goal violation but is unable to fix it.

BalanceCannotBeImprovedException(String) - Constructor for exception org.apache.kafka.common.errors.BalanceCannotBeImprovedException

BalanceCannotBeImprovedException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalanceCannotBeImprovedException

balancednessScorePostRebalance() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanDetailedClusterBalanceStats

Cluster balancedness score after cluster rebalance.

balancednessScorePreRebalance() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanDetailedClusterBalanceStats

Cluster balancedness score before cluster rebalance.

BalancerBrokerExcludedForReplicaPlacementException - Exception in org.apache.kafka.common.errors

Thrown when a Confluent Balancer operation is rendered invalid because of a replica exclusion placed on a broker.

BalancerBrokerExcludedForReplicaPlacementException(String) - Constructor for exception org.apache.kafka.common.errors.BalancerBrokerExcludedForReplicaPlacementException

BalancerBrokerExcludedForReplicaPlacementException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalancerBrokerExcludedForReplicaPlacementException

BalancerJbodEnabledMisconfigurationException - Exception in org.apache.kafka.common.errors

Thrown when the Confluent Balancer is not able to start because JBOD is enabled for the cluster.

BalancerJbodEnabledMisconfigurationException(String) - Constructor for exception org.apache.kafka.common.errors.BalancerJbodEnabledMisconfigurationException

BalancerJbodEnabledMisconfigurationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalancerJbodEnabledMisconfigurationException

BalancerLoadError - Exception in org.apache.kafka.common.errors

Thrown when the Confluent Balancer plugin cannot be loaded.

BalancerLoadError(String) - Constructor for exception org.apache.kafka.common.errors.BalancerLoadError

BalancerLoadError(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalancerLoadError

BalancerMisconfigurationException - Exception in org.apache.kafka.common.errors

BalancerMisconfigurationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalancerMisconfigurationException

BalancerMisconfigurationException(String) - Constructor for exception org.apache.kafka.common.errors.BalancerMisconfigurationException

BalancerOfflineException - Exception in org.apache.kafka.common.errors

Thrown when the Confluent Balancer component is not ready to process requests, either because it is not enabled or because it has not managed to start yet.

BalancerOfflineException(String) - Constructor for exception org.apache.kafka.common.errors.BalancerOfflineException

BalancerOfflineException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalancerOfflineException

BalancerOperationError - Class in org.apache.kafka.clients.admin

The error that caused a balancer operation (broker removal, broker addition) to end up in the status it is in.

BalancerOperationError(Errors, String) - Constructor for class org.apache.kafka.clients.admin.BalancerOperationError

balancerOperationError() - Method in class org.apache.kafka.clients.admin.BalancerStatusDescription

An optional error that gives context as to why the balancer is in the given state.

BalancerOperationFailedException - Exception in org.apache.kafka.common.errors

A general exception for any failure related to a user-initiated Confluent Balancer operation

BalancerOperationFailedException(String) - Constructor for exception org.apache.kafka.common.errors.BalancerOperationFailedException

BalancerOperationFailedException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BalancerOperationFailedException

BalancerOperationStatus - Enum in org.apache.kafka.clients.admin

A high-level status of any given Confluent Balancer operation.

BalancerSelfHealMode - Enum in org.apache.kafka.clients.admin

The status of how Confluent Balancer component self-heals.

BalancerStatus - Enum in org.apache.kafka.clients.admin

The status of the Confluent Balancer component.

balancerStatus() - Method in class org.apache.kafka.clients.admin.BalancerStatusDescription

The current status of the Confluent Balancer component.

BalancerStatusDescription - Class in org.apache.kafka.clients.admin

A description of the balancer status which is fetched via ConfluentAdmin.describeBalancerStatus(DescribeBalancerStatusOptions).

BalancerStatusDescription(BalancerStatus, Collection<Integer>, BalancerOperationError) - Constructor for class org.apache.kafka.clients.admin.BalancerStatusDescription

BasicOAuthBearerToken - Class in org.apache.kafka.common.security.oauthbearer.secured

An implementation of the OAuthBearerToken that fairly straightforwardly stores the values given to its constructor (except the scope set which is copied to avoid modifications).

BasicOAuthBearerToken(String, Set<String>, long, String, Long) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.BasicOAuthBearerToken

Creates a new OAuthBearerToken instance around the given values.

BATCH_SIZE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

batch.size

beforeOffset(long) - Static method in class org.apache.kafka.clients.admin.RecordsToDelete

Delete all the records before the given offset

beforeOffset() - Method in class org.apache.kafka.clients.admin.RecordsToDelete

The offset before which all records will be deleted

beginningOffsets(Collection<TopicPartition>) - Method in interface org.apache.kafka.clients.consumer.Consumer

beginningOffsets(Collection<TopicPartition>, Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

beginningOffsets(Collection<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the first offset for the given partitions.

beginningOffsets(Collection<TopicPartition>, Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the first offset for the given partitions.

beginningOffsets(Collection<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.MockConsumer

beginningOffsets(Collection<TopicPartition>, Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

beginTransaction() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Should be called before the start of each new transaction.

beginTransaction() - Method in class org.apache.kafka.clients.producer.MockProducer

beginTransaction() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.beginTransaction()

beginTransactionException - Variable in class org.apache.kafka.clients.producer.MockProducer

between(Number, Number) - Static method in class org.apache.kafka.common.config.ConfigDef.Range

A numeric range that checks both the upper (inclusive) and lower bound

binding() - Method in class org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult

Return the deleted ACL binding or null if there was an error.

bins() - Method in interface org.apache.kafka.common.metrics.stats.Histogram.BinScheme

Get the number of bins.

bins() - Method in class org.apache.kafka.common.metrics.stats.Histogram.ConstantBinScheme

bins() - Method in class org.apache.kafka.common.metrics.stats.Histogram.LinearBinScheme

bootstrap(List<InetSocketAddress>) - Static method in class org.apache.kafka.common.Cluster

Create a "bootstrap" cluster using the given list of host/ports

BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

bootstrap.servers

BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

bootstrap.servers

BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

bootstrap.servers

bound() - Method in class org.apache.kafka.common.metrics.Quota

bound() - Method in exception org.apache.kafka.common.metrics.QuotaViolationException

BrokerAdditionDescription - Class in org.apache.kafka.clients.admin

A description of a broker addition operation, which has been listed via ConfluentAdmin.describeBrokerAdditions(DescribeBrokerAdditionsOptions).

BrokerAdditionDescription(int, BalancerOperationStatus, PartitionReassignmentsStatus, Optional<BalancerOperationError>, long, long) - Constructor for class org.apache.kafka.clients.admin.BrokerAdditionDescription

BrokerAdditionInProgressException - Exception in org.apache.kafka.common.errors

Thrown if a broker addition request for a specific broker/s is currently being executed.

BrokerAdditionInProgressException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerAdditionInProgressException

BrokerFailureFixInProgressException - Exception in org.apache.kafka.common.errors

Thrown if there are dead brokers in the cluster and balancer is working on fixing it.

BrokerFailureFixInProgressException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerFailureFixInProgressException

brokerId() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

brokerId() - Method in class org.apache.kafka.clients.admin.BrokerLeadershipPriorityResult

The brokerId to change leadership priority on.

brokerId() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

brokerId() - Method in class org.apache.kafka.clients.admin.DemotedBroker

The brokerId to change leadership priority on.

brokerId() - Method in class org.apache.kafka.clients.admin.DescribeBrokerReplicaExclusionsResult.BrokerReplicaExclusionDescription

brokerId(int) - Method in class org.apache.kafka.clients.admin.DescribeProducersOptions

brokerId() - Method in class org.apache.kafka.clients.admin.DescribeProducersOptions

brokerId() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

ID of the broker.

brokerId() - Method in exception org.apache.kafka.common.errors.UnrepresentableBrokerIdException

brokerId() - Method in class org.apache.kafka.common.TopicPartitionReplica

brokerId() - Method in interface org.apache.kafka.server.authorizer.AuthorizerServerInfo

Returns broker id.

BrokerIdNotRegisteredException - Exception in org.apache.kafka.common.errors

BrokerIdNotRegisteredException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerIdNotRegisteredException

BrokerIdNotRegisteredException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BrokerIdNotRegisteredException

brokerIds() - Method in class org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec

The list of brokers to alter leadership priority.

brokerIds() - Method in class org.apache.kafka.clients.admin.BalancerStatusDescription

IDs of the brokers where Confluent Balancer component is running.

BrokerLeadershipPriorityResult - Class in org.apache.kafka.clients.admin

BrokerLeadershipPriorityResult.LeadershipPriorityEnum - Enum in org.apache.kafka.clients.admin

BrokerNotAvailableException - Exception in org.apache.kafka.common.errors

BrokerNotAvailableException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerNotAvailableException

BrokerNotAvailableException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BrokerNotAvailableException

brokerRelatedStats() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlan

Broker-related statistics.

BrokerRemovalCanceledException - Exception in org.apache.kafka.common.errors

Thrown if a broker removal request for the specific broker was canceled.

BrokerRemovalCanceledException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerRemovalCanceledException

BrokerRemovalCanceledException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BrokerRemovalCanceledException

BrokerRemovalDescription - Class in org.apache.kafka.clients.admin

A description of a broker removal, which has been listed via ConfluentAdmin.describeBrokerRemovals(DescribeBrokerRemovalsOptions).

BrokerRemovalDescription(Integer, BalancerOperationStatus, BrokerShutdownStatus, PartitionReassignmentsStatus, Optional<BrokerRemovalError>, long, long) - Constructor for class org.apache.kafka.clients.admin.BrokerRemovalDescription

Deprecated.

BrokerRemovalDescription(Integer, BalancerOperationStatus, BrokerShutdownStatus, PartitionReassignmentsStatus, BrokerReplicaExclusionStatus, boolean, Optional<BrokerRemovalError>, long, long) - Constructor for class org.apache.kafka.clients.admin.BrokerRemovalDescription

BrokerRemovalError - Class in org.apache.kafka.clients.admin

The error that caused a broker removal operation to fail.

BrokerRemovalError(Errors, String) - Constructor for class org.apache.kafka.clients.admin.BrokerRemovalError

BrokerRemovalInProgressException - Exception in org.apache.kafka.common.errors

Thrown if a broker removal request for the specific broker is currently being executed

BrokerRemovalInProgressException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerRemovalInProgressException

BrokerRemovedException - Exception in org.apache.kafka.common.errors

Thrown if a broker removal request for the specific broker has been previously completed

BrokerRemovedException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerRemovedException

BrokerReplicaExclusionDescription(int, String) - Constructor for class org.apache.kafka.clients.admin.DescribeBrokerReplicaExclusionsResult.BrokerReplicaExclusionDescription

BrokerReplicaExclusionNotFoundException - Exception in org.apache.kafka.common.errors

Thrown when the replica exclusion was not found, typically during an attempt to delete it

BrokerReplicaExclusionNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.BrokerReplicaExclusionNotFoundException

BrokerReplicaExclusionNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.BrokerReplicaExclusionNotFoundException

brokerReplicaExclusionStatus() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

Nullable for server versions below 7.0, the status of the broker replica exclusion subtask of the broker removal operation.

BrokerReplicaExclusionStatus - Enum in org.apache.kafka.clients.admin

Denotes the status of the broker replica exclusion sub task of a given Confluent Balancer operation.

brokersExcludedForLeadership() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerRelatedStats

Brokers excluded for assigning replica leadership.

brokersExcludedForReplicaMove() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerRelatedStats

Brokers that cannot move replicas in or out of them.

BrokerShutdownStatus - Enum in org.apache.kafka.clients.admin

Denotes the status of the broker shutdown sub task of a given Confluent Balancer operation.

BUFFER_MEMORY_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

buffer.memory

BufferExhaustedException - Exception in org.apache.kafka.clients.producer

This exception is thrown if the producer cannot allocate memory for a record within max.block.ms due to the buffer being too full.

BufferExhaustedException(String) - Constructor for exception org.apache.kafka.clients.producer.BufferExhaustedException

build(AuthenticationContext) - Method in interface org.apache.kafka.common.security.auth.KafkaPrincipalBuilder

Build a kafka principal from the authentication context.

byBrokerId() - Method in class org.apache.kafka.clients.admin.ListTransactionsResult

Get a future which returns a map containing the underlying listing future for each broker in the cluster.

ByteArray() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable byte[] type.

ByteArrayDeserializer - Class in org.apache.kafka.common.serialization

ByteArrayDeserializer() - Constructor for class org.apache.kafka.common.serialization.ByteArrayDeserializer

ByteArraySerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.ByteArraySerde

ByteArraySerializer - Class in org.apache.kafka.common.serialization

ByteArraySerializer() - Constructor for class org.apache.kafka.common.serialization.ByteArraySerializer

ByteBuffer() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable ByteBuffer type.

ByteBufferDeserializer - Class in org.apache.kafka.common.serialization

ByteBufferDeserializer() - Constructor for class org.apache.kafka.common.serialization.ByteBufferDeserializer

ByteBufferSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.ByteBufferSerde

ByteBufferSerializer - Class in org.apache.kafka.common.serialization

ByteBufferSerializer() - Constructor for class org.apache.kafka.common.serialization.ByteBufferSerializer

Bytes() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable Bytes type.

BytesDeserializer - Class in org.apache.kafka.common.serialization

BytesDeserializer() - Constructor for class org.apache.kafka.common.serialization.BytesDeserializer

BytesSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.BytesSerde

BytesSerializer - Class in org.apache.kafka.common.serialization

BytesSerializer() - Constructor for class org.apache.kafka.common.serialization.BytesSerializer

C

call() - Method in interface org.apache.kafka.common.security.oauthbearer.secured.Retryable

Perform the operation and return the data from the response.

Callback - Interface in org.apache.kafka.clients.producer

A callback interface that the user can implement to allow code to execute when the request is complete.

cancel(boolean) - Method in class org.apache.kafka.common.KafkaFuture

If not already completed, completes this future with a CancellationException.

centerValue() - Method in class org.apache.kafka.common.metrics.stats.Frequency

Get the value of this metrics center point.

CHECK_CRCS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

check.crcs

checkQuotas() - Method in class org.apache.kafka.common.metrics.Sensor

Check if we have violated our quota for any metric that has a configured quota

checkQuotas(long) - Method in class org.apache.kafka.common.metrics.Sensor

ClaimValidationUtils - Class in org.apache.kafka.common.security.oauthbearer.secured

Simple utility class to perform basic cleaning and validation on input values so that they're performed consistently throughout the code base.

ClaimValidationUtils() - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.ClaimValidationUtils

CLEANUP_POLICY_COMPACT - Static variable in class org.apache.kafka.common.config.TopicConfig

CLEANUP_POLICY_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

CLEANUP_POLICY_DELETE - Static variable in class org.apache.kafka.common.config.TopicConfig

CLEANUP_POLICY_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

clear() - Method in class org.apache.kafka.clients.producer.MockProducer

Clear the stored history of sent records, consumer group offsets

clear() - Method in class org.apache.kafka.common.metrics.stats.Histogram

CLIENT_DNS_LOOKUP_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

client.dns.lookup

CLIENT_DNS_LOOKUP_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

client.dns.lookup

CLIENT_DNS_LOOKUP_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

client.dns.lookup

CLIENT_ID - Static variable in class org.apache.kafka.common.quota.ClientQuotaEntity

CLIENT_ID_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

CLIENT_ID_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

client.id

CLIENT_ID_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

client.id

CLIENT_ID_CONFIG - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

CLIENT_ID_DOC - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

CLIENT_RACK_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

client.rack

CLIENT_SECRET_CONFIG - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

CLIENT_SECRET_DOC - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

clientAddress() - Method in interface org.apache.kafka.common.security.auth.AuthenticationContext

Address of the authenticated client

clientAddress() - Method in class org.apache.kafka.common.security.auth.PlaintextAuthenticationContext

clientAddress() - Method in class org.apache.kafka.common.security.auth.SaslAuthenticationContext

clientAddress() - Method in class org.apache.kafka.common.security.auth.SslAuthenticationContext

clientAddress() - Method in interface org.apache.kafka.server.authorizer.AuthorizableRequestContext

Returns client IP address from which request was sent.

clientId() - Method in class org.apache.kafka.clients.admin.MemberDescription

The client id of the group member.

clientId() - Method in interface org.apache.kafka.server.authorizer.AuthorizableRequestContext

Returns the client id from the request header.

ClientQuotaAlteration - Class in org.apache.kafka.common.quota

Describes a configuration alteration to be made to a client quota entity.

ClientQuotaAlteration(ClientQuotaEntity, Collection<ClientQuotaAlteration.Op>) - Constructor for class org.apache.kafka.common.quota.ClientQuotaAlteration

ClientQuotaAlteration.Op - Class in org.apache.kafka.common.quota

ClientQuotaCallback - Interface in org.apache.kafka.server.quota

Quota callback interface for brokers that enables customization of client quota computation.

ClientQuotaEntity - Class in org.apache.kafka.common.quota

Describes a client quota entity, which is a mapping of entity types to their names.

ClientQuotaEntity(Map<String, String>) - Constructor for class org.apache.kafka.common.quota.ClientQuotaEntity

Constructs a quota entity for the given types and names.

ClientQuotaEntity - Interface in org.apache.kafka.server.quota

The metadata for an entity for which quota is configured.

ClientQuotaEntity.ConfigEntity - Interface in org.apache.kafka.server.quota

Interface representing a quota configuration entity.

ClientQuotaEntity.ConfigEntityType - Enum in org.apache.kafka.server.quota

Entity type of a ClientQuotaEntity.ConfigEntity

ClientQuotaFilter - Class in org.apache.kafka.common.quota

Describes a client quota entity filter.

ClientQuotaFilterComponent - Class in org.apache.kafka.common.quota

Describes a component for applying a client quota filter.

ClientQuotaType - Enum in org.apache.kafka.server.quota

Types of quotas that may be configured on brokers for client requests.

close() - Method in interface org.apache.kafka.clients.admin.Admin

Close the Admin and release all associated resources.

close(Duration) - Method in interface org.apache.kafka.clients.admin.Admin

Close the Admin client and release all associated resources.

close(Duration) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

close() - Method in interface org.apache.kafka.clients.consumer.Consumer

close(Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

close() - Method in interface org.apache.kafka.clients.consumer.ConsumerInterceptor

This is called when interceptor is closed

close() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Close the consumer, waiting for up to the default timeout of 30 seconds for any needed cleanup.

close(Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Tries to close the consumer cleanly within the specified timeout.

close() - Method in class org.apache.kafka.clients.consumer.MockConsumer

close(Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

close() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Close this producer.

close(Duration) - Method in class org.apache.kafka.clients.producer.KafkaProducer

This method waits up to timeout for the producer to complete the sending of all incomplete requests.

close() - Method in class org.apache.kafka.clients.producer.MockProducer

close(Duration) - Method in class org.apache.kafka.clients.producer.MockProducer

close() - Method in interface org.apache.kafka.clients.producer.Partitioner

This is called when partitioner is closed.

close() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.close()

close(Duration) - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.close(Duration)

close() - Method in interface org.apache.kafka.clients.producer.ProducerInterceptor

This is called when interceptor is closed

close() - Method in class org.apache.kafka.clients.producer.RoundRobinPartitioner

close() - Method in class org.apache.kafka.clients.producer.UniformStickyPartitioner

Deprecated.

close() - Method in class org.apache.kafka.common.config.provider.DirectoryConfigProvider

close() - Method in class org.apache.kafka.common.config.provider.FileConfigProvider

close() - Method in interface org.apache.kafka.common.MessageFormatter

Closes the formatter

close() - Method in class org.apache.kafka.common.metrics.JmxReporter

close() - Method in class org.apache.kafka.common.metrics.Metrics

Close this metrics repository.

close() - Method in interface org.apache.kafka.common.metrics.MetricsReporter

Called when the metrics repository is closed.

close() - Method in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

Closes this instance.

close() - Method in interface org.apache.kafka.common.security.auth.Login

Closes this instance.

close() - Method in interface org.apache.kafka.common.security.oauthbearer.secured.AccessTokenRetriever

Lifecycle method to perform a clean shutdown of the retriever.

close() - Method in interface org.apache.kafka.common.security.oauthbearer.secured.CloseableVerificationKeyResolver

Lifecycle method to perform a clean shutdown of the VerificationKeyResolver.

close() - Method in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

close() - Method in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler

close() - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwks

close() - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwksVerificationKeyResolver

close() - Method in interface org.apache.kafka.common.serialization.Deserializer

Close this deserializer.

close() - Method in class org.apache.kafka.common.serialization.ListDeserializer

close() - Method in class org.apache.kafka.common.serialization.ListSerializer

close() - Method in interface org.apache.kafka.common.serialization.Serde

Close this serde class, which will close the underlying serializer and deserializer.

close() - Method in class org.apache.kafka.common.serialization.Serdes.WrapperSerde

close() - Method in interface org.apache.kafka.common.serialization.Serializer

Close this serializer.

close() - Method in interface org.apache.kafka.server.quota.ClientQuotaCallback

Closes this instance.

CloseableVerificationKeyResolver - Interface in org.apache.kafka.common.security.oauthbearer.secured

The OAuthBearerValidatorCallbackHandler uses a VerificationKeyResolver as part of its validation of the incoming JWT.

closed() - Method in class org.apache.kafka.clients.consumer.MockConsumer

closed() - Method in class org.apache.kafka.clients.producer.MockProducer

closeException - Variable in class org.apache.kafka.clients.producer.MockProducer

Cluster - Class in org.apache.kafka.common

An immutable representation of a subset of the nodes, topics, and partitions in the Kafka cluster.

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>) - Constructor for class org.apache.kafka.common.Cluster

Create a new cluster with the given id, nodes and partitions

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Node) - Constructor for class org.apache.kafka.common.Cluster

Create a new cluster with the given id, nodes and partitions

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Set<String>, Node) - Constructor for class org.apache.kafka.common.Cluster

Create a new cluster with the given id, nodes and partitions

Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Set<String>, Node, Map<String, Uuid>) - Constructor for class org.apache.kafka.common.Cluster

Create a new cluster with the given id, nodes, partitions and topicIds

CLUSTER - Static variable in class org.apache.kafka.common.resource.Resource

A resource representing the whole cluster.

CLUSTER_NAME - Static variable in class org.apache.kafka.common.resource.Resource

The name of the CLUSTER resource.

ClusterAuthorizationException - Exception in org.apache.kafka.common.errors

Exception indicates authorization failure to perform cluster link operations.

ClusterAuthorizationException(String) - Constructor for exception org.apache.kafka.common.errors.ClusterAuthorizationException

ClusterAuthorizationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ClusterAuthorizationException

clusterBalancedness() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlan

Cluster balancedness information.

clusterId() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

The linked cluster's ID, or null if none.

clusterId() - Method in class org.apache.kafka.clients.admin.DescribeClusterResult

Returns a future which yields the current cluster id.

clusterId() - Method in class org.apache.kafka.clients.admin.NewClusterLink

The ID of the cluster link, or null if not provided.

clusterId() - Method in class org.apache.kafka.common.ClusterResource

Return the cluster id.

ClusterLevelQuotaCallback - Interface in org.apache.kafka.server.quota

ClusterLinkDescription - Class in org.apache.kafka.clients.admin

A description of a cluster that's linked.

ClusterLinkDescription(String, Uuid, String, String, Collection<String>, ClusterLinkDescription.LinkState, ClusterLinkDescription.LinkMode, ClusterLinkDescription.ConnectionMode) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkDescription

Creates a cluster link description.

ClusterLinkDescription.ConnectionMode - Enum in org.apache.kafka.clients.admin

ClusterLinkDescription.LinkMode - Enum in org.apache.kafka.clients.admin

ClusterLinkDescription.LinkState - Enum in org.apache.kafka.clients.admin

ClusterLinkDisabledException - Exception in org.apache.kafka.common.errors

Exception indicates that the cluster link is disabled.

ClusterLinkDisabledException(String) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkDisabledException

ClusterLinkDisabledException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkDisabledException

ClusterLinkExistsException - Exception in org.apache.kafka.common.errors

Indicates that the link name for the cluster link creation already exists.

ClusterLinkExistsException(String) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkExistsException

ClusterLinkExistsException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkExistsException

clusterLinkId() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

clusterLinkId() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

The Uuid of the cluster link that uniquely represents this cluster link.

clusterLinkId() - Method in class org.apache.kafka.clients.admin.MirrorTopicDescription

The Uuid of the cluster link for the mirror topic.

clusterLinkIds() - Method in class org.apache.kafka.common.acl.AccessControlEntry

clusterLinkIds() - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

Return the cluster link ids associated with this filter.

ClusterLinkInUseException - Exception in org.apache.kafka.common.errors

Indicates that the cluster link could not be deleted because it is currently in use by one or more services.

ClusterLinkInUseException(String) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkInUseException

ClusterLinkInUseException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkInUseException

ClusterLinkListing - Class in org.apache.kafka.clients.admin

A listing of a cluster that's linked.

ClusterLinkListing(String, UUID, String, String, Optional<Collection<String>>, boolean) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkListing

Deprecated.

ClusterLinkListing(String, Uuid, String, String, Optional<Collection<String>>, boolean) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkListing

Creates an cluster link listing.

ClusterLinkNotFoundException - Exception in org.apache.kafka.common.errors

Indicates that the cluster link for the given link name was not found.

ClusterLinkNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkNotFoundException

ClusterLinkNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkNotFoundException

ClusterLinkPausedException - Exception in org.apache.kafka.common.errors

Indicates that the cluster link is paused and therefore should not be operated on.

ClusterLinkPausedException(String) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkPausedException

ClusterLinkPausedException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ClusterLinkPausedException

clusterLoadPostRebalance() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanDetailedClusterBalanceStats

Cluster statistics after cluster rebalance.

clusterLoadPreRebalance() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanDetailedClusterBalanceStats

Cluster statistics before cluster rebalance.

clusterQuotaLimit(ClientQuotaType, Map<String, String>) - Method in interface org.apache.kafka.server.quota.ClusterLevelQuotaCallback

clusterRelatedStats() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlan

Cluster-related statistics.

clusterResource() - Method in class org.apache.kafka.common.Cluster

ClusterResource - Class in org.apache.kafka.common

The ClusterResource class encapsulates metadata for a Kafka cluster.

ClusterResource(String) - Constructor for class org.apache.kafka.common.ClusterResource

Create ClusterResource with a cluster id.

clusterResource() - Method in interface org.apache.kafka.server.authorizer.AuthorizerServerInfo

Returns cluster metadata for the broker running this authorizer including cluster id.

ClusterResourceListener - Interface in org.apache.kafka.common

A callback interface that users can implement when they wish to get notified about changes in the Cluster metadata.

code() - Method in enum org.apache.kafka.clients.admin.FeatureUpdate.UpgradeType

code() - Method in enum org.apache.kafka.common.acl.AclOperation

Return the code of this operation.

code() - Method in enum org.apache.kafka.common.acl.AclPermissionType

Return the code of this permission type.

code() - Method in enum org.apache.kafka.common.resource.PatternType

code() - Method in enum org.apache.kafka.common.resource.ResourceType

Return the code of this resource.

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Avg

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.ExponentialWeightedAvg

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Frequencies

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Max

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Min

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Percentiles

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.SampledStat

combine(List<SampledStat.Sample>, MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.WindowedSum

commit() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule

commit() - Method in class org.apache.kafka.common.security.plain.PlainLoginModule

commit() - Method in class org.apache.kafka.common.security.scram.ScramLoginModule

commitAsync() - Method in interface org.apache.kafka.clients.consumer.Consumer

commitAsync(OffsetCommitCallback) - Method in interface org.apache.kafka.clients.consumer.Consumer

commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback) - Method in interface org.apache.kafka.clients.consumer.Consumer

commitAsync() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit offsets returned on the last KafkaConsumer.poll(Duration) for all the subscribed list of topics and partition.

commitAsync(OffsetCommitCallback) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit offsets returned on the last poll() for the subscribed list of topics and partitions.

commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit the specified offsets for the specified list of topics and partitions to Kafka.

commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback) - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitAsync() - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitAsync(OffsetCommitCallback) - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitCount() - Method in class org.apache.kafka.clients.producer.MockProducer

CommitFailedException - Exception in org.apache.kafka.clients.consumer

This exception is raised when an offset commit with KafkaConsumer.commitSync() fails with an unrecoverable error.

CommitFailedException(String) - Constructor for exception org.apache.kafka.clients.consumer.CommitFailedException

CommitFailedException() - Constructor for exception org.apache.kafka.clients.consumer.CommitFailedException

commitSync() - Method in interface org.apache.kafka.clients.consumer.Consumer

commitSync(Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

commitSync(Map<TopicPartition, OffsetAndMetadata>) - Method in interface org.apache.kafka.clients.consumer.Consumer

commitSync(Map<TopicPartition, OffsetAndMetadata>, Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

commitSync() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit offsets returned on the last poll() for all the subscribed list of topics and partitions.

commitSync(Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit offsets returned on the last poll() for all the subscribed list of topics and partitions.

commitSync(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit the specified offsets for the specified list of topics and partitions.

commitSync(Map<TopicPartition, OffsetAndMetadata>, Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Commit the specified offsets for the specified list of topics and partitions.

commitSync(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitSync() - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitSync(Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitSync(Map<TopicPartition, OffsetAndMetadata>, Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

committed(TopicPartition) - Method in interface org.apache.kafka.clients.consumer.Consumer

Deprecated.

committed(TopicPartition, Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

Deprecated.

committed(Set<TopicPartition>) - Method in interface org.apache.kafka.clients.consumer.Consumer

committed(Set<TopicPartition>, Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

committed(TopicPartition) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Deprecated.

since 2.4 Use KafkaConsumer.committed(Set) instead

committed(TopicPartition, Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Deprecated.

since 2.4 Use KafkaConsumer.committed(Set, Duration) instead

committed(Set<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the last committed offsets for the given partitions (whether the commit happened by this process or another).

committed(Set<TopicPartition>, Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the last committed offsets for the given partitions (whether the commit happened by this process or another).

committed(TopicPartition) - Method in class org.apache.kafka.clients.consumer.MockConsumer

Deprecated.

committed(TopicPartition, Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

Deprecated.

committed(Set<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.MockConsumer

committed(Set<TopicPartition>, Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

commitTransaction() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Commits the ongoing transaction.

commitTransaction() - Method in class org.apache.kafka.clients.producer.MockProducer

commitTransaction() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.commitTransaction()

commitTransactionException - Variable in class org.apache.kafka.clients.producer.MockProducer

COMPACTED_TOPIC_PREFER_TIER_FETCH_MS_CONFIG - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

COMPACTED_TOPIC_PREFER_TIER_FETCH_MS_DOC - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

compareTo(Uuid) - Method in class org.apache.kafka.common.Uuid

compilePredicate(Map<String, ?>) - Static method in class org.apache.kafka.common.metrics.JmxReporter

complete(T) - Method in class org.apache.kafka.common.KafkaFuture

If not already completed, sets the value returned by get() and related methods to the given value.

completedFuture(U) - Static method in class org.apache.kafka.common.KafkaFuture

Returns a new KafkaFuture that is already completed with the given value.

completeExceptionally(Throwable) - Method in class org.apache.kafka.common.KafkaFuture

If not already completed, causes invocations of get() and related methods to throw the given exception.

completeNext() - Method in class org.apache.kafka.clients.producer.MockProducer

Complete the earliest uncompleted call successfully.

components() - Method in class org.apache.kafka.common.quota.ClientQuotaFilter

CompoundStat - Interface in org.apache.kafka.common.metrics

A compound stat is a stat where a single measurement and associated data structure feeds many metrics.

CompoundStat.NamedMeasurable - Class in org.apache.kafka.common.metrics

COMPRESSION_TYPE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

compression.type

COMPRESSION_TYPE_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

COMPRESSION_TYPE_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

computeEvenClusterLoadPlan() - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Compute even cluster load plan for the cluster.

computeEvenClusterLoadPlan(ComputeEvenClusterLoadPlanOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Compute and return an even cluster load plan for the cluster based on the rebalance goals.

computeEvenClusterLoadPlan(ComputeEvenClusterLoadPlanOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ComputeEvenClusterLoadPlanOptions - Class in org.apache.kafka.clients.admin

Options for the even cluster load plan computation.

ComputeEvenClusterLoadPlanOptions() - Constructor for class org.apache.kafka.clients.admin.ComputeEvenClusterLoadPlanOptions

ComputeEvenClusterLoadPlanResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.computeEvenClusterLoadPlan(ComputeEvenClusterLoadPlanOptions).

ConcurrentTransactionsException - Exception in org.apache.kafka.common.errors

ConcurrentTransactionsException(String) - Constructor for exception org.apache.kafka.common.errors.ConcurrentTransactionsException

Config - Class in org.apache.kafka.clients.admin

A configuration object containing the configuration entries for a resource.

Config(Collection<ConfigEntry>) - Constructor for class org.apache.kafka.clients.admin.Config

Create a configuration instance with the provided entries.

config(String) - Method in class org.apache.kafka.clients.admin.CreateTopicsResult

Returns a future that provides topic configs for the topic when the request completes.

config() - Method in class org.apache.kafka.clients.admin.CreateTopicsResult.TopicMetadataAndConfig

Config - Class in org.apache.kafka.common.config

Config(List<ConfigValue>) - Constructor for class org.apache.kafka.common.config.Config

config() - Method in class org.apache.kafka.common.metrics.KafkaMetric

config(MetricConfig) - Method in class org.apache.kafka.common.metrics.KafkaMetric

config() - Method in class org.apache.kafka.common.metrics.Metrics

CONFIG_PROVIDERS_CONFIG - Static variable in class org.apache.kafka.common.config.AbstractConfig

ConfigChangeCallback - Interface in org.apache.kafka.common.config

A callback passed to ConfigProvider for subscribing to changes.

ConfigData - Class in org.apache.kafka.common.config

Configuration data from a ConfigProvider.

ConfigData(Map<String, String>, Long) - Constructor for class org.apache.kafka.common.config.ConfigData

Creates a new ConfigData with the given data and TTL (in milliseconds).

ConfigData(Map<String, String>) - Constructor for class org.apache.kafka.common.config.ConfigData

Creates a new ConfigData with the given data.

configDef() - Static method in class org.apache.kafka.clients.admin.AdminClientConfig

configDef() - Static method in class org.apache.kafka.clients.consumer.ConsumerConfig

configDef() - Static method in class org.apache.kafka.clients.producer.ProducerConfig

ConfigDef - Class in org.apache.kafka.common.config

This class is used for specifying the set of expected configurations.

ConfigDef() - Constructor for class org.apache.kafka.common.config.ConfigDef

ConfigDef(ConfigDef) - Constructor for class org.apache.kafka.common.config.ConfigDef

ConfigDef.CaseInsensitiveValidString - Class in org.apache.kafka.common.config

ConfigDef.CompositeValidator - Class in org.apache.kafka.common.config

ConfigDef.ConcreteSubClassValidator - Class in org.apache.kafka.common.config

ConfigDef.ConfigKey - Class in org.apache.kafka.common.config

ConfigDef.Importance - Enum in org.apache.kafka.common.config

The importance level for a configuration

ConfigDef.InstantiableClassValidator - Class in org.apache.kafka.common.config

ConfigDef.LambdaValidator - Class in org.apache.kafka.common.config

ConfigDef.ListSize - Class in org.apache.kafka.common.config

ConfigDef.NonEmptyString - Class in org.apache.kafka.common.config

ConfigDef.NonEmptyStringWithoutControlChars - Class in org.apache.kafka.common.config

ConfigDef.NonNullValidator - Class in org.apache.kafka.common.config

ConfigDef.Range - Class in org.apache.kafka.common.config

Validation logic for numeric ranges

ConfigDef.Recommender - Interface in org.apache.kafka.common.config

This is used by the ConfigDef.validate(Map) to get valid values for a configuration given the current configuration values in order to perform full configuration validation and visibility modification.

ConfigDef.Type - Enum in org.apache.kafka.common.config

The config types

ConfigDef.Validator - Interface in org.apache.kafka.common.config

Validation logic the user may provide to perform single configuration validation.

ConfigDef.ValidList - Class in org.apache.kafka.common.config

ConfigDef.ValidString - Class in org.apache.kafka.common.config

ConfigDef.Width - Enum in org.apache.kafka.common.config

The width of a configuration value

configEntities() - Method in interface org.apache.kafka.server.quota.ClientQuotaEntity

Returns the list of configuration entities that this quota entity is comprised of.

configEntry() - Method in class org.apache.kafka.clients.admin.AlterConfigOp

ConfigEntry - Class in org.apache.kafka.clients.admin

A class representing a configuration entry containing name, value and additional metadata.

ConfigEntry(String, String) - Constructor for class org.apache.kafka.clients.admin.ConfigEntry

Create a configuration entry with the provided values.

ConfigEntry(String, String, ConfigEntry.ConfigSource, boolean, boolean, List<ConfigEntry.ConfigSynonym>, ConfigEntry.ConfigType, String) - Constructor for class org.apache.kafka.clients.admin.ConfigEntry

Create a configuration with the provided values.

ConfigEntry.ConfigSource - Enum in org.apache.kafka.clients.admin

Source of configuration entries.

ConfigEntry.ConfigSynonym - Class in org.apache.kafka.clients.admin

Class representing a configuration synonym of a ConfigEntry.

ConfigEntry.ConfigType - Enum in org.apache.kafka.clients.admin

Data type of configuration entry.

ConfigException - Exception in org.apache.kafka.common.config

Thrown if the user supplies an invalid configuration

ConfigException(String) - Constructor for exception org.apache.kafka.common.config.ConfigException

ConfigException(String, Object) - Constructor for exception org.apache.kafka.common.config.ConfigException

ConfigException(String, Object, String) - Constructor for exception org.apache.kafka.common.config.ConfigException

ConfigKey(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender, boolean) - Constructor for class org.apache.kafka.common.config.ConfigDef.ConfigKey

configKeys() - Method in class org.apache.kafka.common.config.ConfigDef

Get the configuration keys

configNames() - Static method in class org.apache.kafka.clients.admin.AdminClientConfig

configNames() - Static method in class org.apache.kafka.clients.consumer.ConsumerConfig

configNames() - Static method in class org.apache.kafka.clients.producer.ProducerConfig

ConfigProvider - Interface in org.apache.kafka.common.config.provider

A provider of configuration data, which may optionally support subscriptions to configuration changes.

ConfigResource - Class in org.apache.kafka.common.config

A class representing resources that have configs.

ConfigResource(ConfigResource.Type, String) - Constructor for class org.apache.kafka.common.config.ConfigResource

Create an instance of this class with the provided parameters.

ConfigResource.Type - Enum in org.apache.kafka.common.config

Type of resource.

configs() - Method in class org.apache.kafka.clients.admin.NewClusterLink

The configuration for the new cluster link.

configs(Map<String, String>) - Method in class org.apache.kafka.clients.admin.NewTopic

Set the configuration to use on the new topic.

configs() - Method in class org.apache.kafka.clients.admin.NewTopic

The configuration for the new topic or null if no configs ever specified.

configs() - Method in class org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata

Return the configs in the request.

configs() - Method in class org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata

Return topic configs in the request, not including broker defaults.

ConfigTransformer - Class in org.apache.kafka.common.config

This class wraps a set of ConfigProvider instances and uses them to perform transformations.

ConfigTransformer(Map<String, ConfigProvider>) - Constructor for class org.apache.kafka.common.config.ConfigTransformer

Creates a ConfigTransformer with the default pattern, of the form ${provider:[path:]key}.

ConfigTransformerResult - Class in org.apache.kafka.common.config

The result of a transformation from ConfigTransformer.

ConfigTransformerResult(Map<String, String>, Map<String, Long>) - Constructor for class org.apache.kafka.common.config.ConfigTransformerResult

Creates a new ConfigTransformerResult with the given data and TTL values for a set of paths.

Configurable - Interface in org.apache.kafka.common

A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters

ConfigurationUtils - Class in org.apache.kafka.common.security.oauthbearer.secured

ConfigurationUtils is a utility class to perform basic configuration-related logic and is separated out here for easier, more direct testing.

ConfigurationUtils(Map<String, ?>) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.ConfigurationUtils

ConfigurationUtils(Map<String, ?>, String) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.ConfigurationUtils

configure(Map<String, ?>) - Method in class org.apache.kafka.clients.producer.RoundRobinPartitioner

configure(Map<String, ?>) - Method in class org.apache.kafka.clients.producer.UniformStickyPartitioner

Deprecated.

configure(Map<String, ?>) - Method in class org.apache.kafka.common.config.provider.DirectoryConfigProvider

configure(Map<String, ?>) - Method in class org.apache.kafka.common.config.provider.FileConfigProvider

configure(Map<String, ?>) - Method in interface org.apache.kafka.common.Configurable

Configure this class with the given key-value pairs

configure(Map<String, ?>) - Method in class org.apache.kafka.common.DelegatingReconfigurable

configure(Map<String, ?>) - Method in interface org.apache.kafka.common.MessageFormatter

Configures the MessageFormatter

configure(Map<String, ?>) - Method in class org.apache.kafka.common.metrics.JmxReporter

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

Configures this callback handler for the specified SASL mechanism.

configure(Map<String, ?>, String, Configuration, AuthenticateCallbackHandler) - Method in interface org.apache.kafka.common.security.auth.Login

Configures this login instance.

configure(Map<String, ?>) - Method in interface org.apache.kafka.common.security.auth.SecurityProviderCreator

Configure method is used to configure the generator to create the Security Provider

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler

configure(Map<String, ?>, boolean) - Method in interface org.apache.kafka.common.serialization.Deserializer

Configure this class.

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.ListDeserializer

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.ListSerializer

configure(Map<String, ?>, boolean) - Method in interface org.apache.kafka.common.serialization.Serde

Configure this class, which will configure the underlying serializer and deserializer.

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.Serdes.WrapperSerde

configure(Map<String, ?>, boolean) - Method in interface org.apache.kafka.common.serialization.Serializer

Configure this class.

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.StringDeserializer

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.StringSerializer

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.UUIDDeserializer

configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.UUIDSerializer

ConfigValue - Class in org.apache.kafka.common.config

ConfigValue(String) - Constructor for class org.apache.kafka.common.config.ConfigValue

ConfigValue(String, Object, List<Object>, List<String>) - Constructor for class org.apache.kafka.common.config.ConfigValue

configValues() - Method in class org.apache.kafka.common.config.Config

Confluent - Annotation Type in org.apache.kafka.common

CONFLUENT_PREFIX - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

ConfluentAdmin - Interface in org.apache.kafka.clients.admin

This interface contains admin client methods that: are only present in Confluent Server, or existing Admin methods that return or take extra information only available in Confluent Server. Any new or update to admin client api that need these features should be done here.

ConfluentNode - Class in org.apache.kafka.common

Information about a Confluent Server node.

ConfluentNode(int, String, int, String, Map<String, String>) - Constructor for class org.apache.kafka.common.ConfluentNode

ConfluentPrincipal - Class in org.apache.kafka.common.security.auth

ConfluentPrincipal(String, String, String) - Constructor for class org.apache.kafka.common.security.auth.ConfluentPrincipal

ConfluentPrincipal(String, String, String, boolean) - Constructor for class org.apache.kafka.common.security.auth.ConfluentPrincipal

ConfluentTopicConfig - Class in org.apache.kafka.common.config

Keys that can be used to configure a topic for Confluent Platform Kafka.

ConfluentTopicConfig() - Constructor for class org.apache.kafka.common.config.ConfluentTopicConfig

connectionMode() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

Connection mode.

CONNECTIONS_MAX_IDLE_MS_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

connections.max.idle.ms

CONNECTIONS_MAX_IDLE_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

connections.max.idle.ms

CONNECTIONS_MAX_IDLE_MS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

connections.max.idle.ms

ConstantBinScheme(int, double, double) - Constructor for class org.apache.kafka.common.metrics.stats.Histogram.ConstantBinScheme

Create a bin scheme with the specified number of bins that all have the same width.

Consumer<K,V> - Interface in org.apache.kafka.clients.consumer

ConsumerConfig - Class in org.apache.kafka.clients.consumer

The consumer configuration keys

ConsumerConfig(Properties) - Constructor for class org.apache.kafka.clients.consumer.ConsumerConfig

ConsumerConfig(Map<String, Object>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerConfig

ConsumerConfig(Map<?, ?>, boolean) - Constructor for class org.apache.kafka.clients.consumer.ConsumerConfig

ConsumerGroupDescription - Class in org.apache.kafka.clients.admin

A detailed description of a single consumer group in the cluster.

ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node) - Constructor for class org.apache.kafka.clients.admin.ConsumerGroupDescription

ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node, Set<AclOperation>) - Constructor for class org.apache.kafka.clients.admin.ConsumerGroupDescription

ConsumerGroupListing - Class in org.apache.kafka.clients.admin

A listing of a consumer group in the cluster.

ConsumerGroupListing(String, boolean) - Constructor for class org.apache.kafka.clients.admin.ConsumerGroupListing

Create an instance with the specified parameters.

ConsumerGroupListing(String, boolean, Optional<ConsumerGroupState>) - Constructor for class org.apache.kafka.clients.admin.ConsumerGroupListing

Create an instance with the specified parameters.

ConsumerGroupMetadata - Class in org.apache.kafka.clients.consumer

A metadata struct containing the consumer group information.

ConsumerGroupMetadata(String, int, String, Optional<String>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

ConsumerGroupMetadata(String) - Constructor for class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

consumerGroupOffsetsHistory() - Method in class org.apache.kafka.clients.producer.MockProducer

Get the list of committed consumer group offsets since the last call to MockProducer.clear()

ConsumerGroupState - Enum in org.apache.kafka.common

The consumer group state.

consumerId() - Method in class org.apache.kafka.clients.admin.MemberDescription

The consumer id of the group member.

ConsumerInterceptor<K,V> - Interface in org.apache.kafka.clients.consumer

A plugin interface that allows you to intercept (and possibly mutate) records received by the consumer.

ConsumerPartitionAssignor - Interface in org.apache.kafka.clients.consumer

This interface is used to define custom partition assignment for use in KafkaConsumer.

ConsumerPartitionAssignor.Assignment - Class in org.apache.kafka.clients.consumer

ConsumerPartitionAssignor.GroupAssignment - Class in org.apache.kafka.clients.consumer

ConsumerPartitionAssignor.GroupSubscription - Class in org.apache.kafka.clients.consumer

ConsumerPartitionAssignor.RebalanceProtocol - Enum in org.apache.kafka.clients.consumer

The rebalance protocol defines partition assignment and revocation semantics.

ConsumerPartitionAssignor.Subscription - Class in org.apache.kafka.clients.consumer

ConsumerRebalanceListener - Interface in org.apache.kafka.clients.consumer

A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the consumer changes.

ConsumerRecord<K,V> - Class in org.apache.kafka.clients.consumer

A key/value pair to be received from Kafka.

ConsumerRecord(String, int, long, K, V) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord

Creates a record to be received from a specified topic and partition (provided for compatibility with Kafka 0.9 before the message format supported timestamps and before serialized metadata were exposed).

ConsumerRecord(String, int, long, long, TimestampType, int, int, K, V, Headers, Optional<Integer>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord

Creates a record to be received from a specified topic and partition

ConsumerRecord(String, int, long, long, TimestampType, long, int, int, K, V) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord

Deprecated.

use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).

ConsumerRecord(String, int, long, long, TimestampType, Long, int, int, K, V, Headers) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord

Deprecated.

use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).

ConsumerRecord(String, int, long, long, TimestampType, Long, int, int, K, V, Headers, Optional<Integer>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord

Deprecated.

use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).

ConsumerRecords<K,V> - Class in org.apache.kafka.clients.consumer

A container that holds the list ConsumerRecord per partition for a particular topic.

ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecords

contains(Collection<ClientQuotaFilterComponent>) - Static method in class org.apache.kafka.common.quota.ClientQuotaFilter

Constructs and returns a quota filter that matches all provided components.

containsMbean(String) - Method in class org.apache.kafka.common.metrics.JmxReporter

containsOnly(Collection<ClientQuotaFilterComponent>) - Static method in class org.apache.kafka.common.quota.ClientQuotaFilter

Constructs and returns a quota filter that matches all provided components.

contextChange(MetricsContext) - Method in class org.apache.kafka.common.metrics.JmxReporter

contextChange(MetricsContext) - Method in interface org.apache.kafka.common.metrics.MetricsReporter

Sets the context labels for the service or library exposing metrics.

contextLabels() - Method in class org.apache.kafka.common.metrics.KafkaMetricsContext

contextLabels() - Method in interface org.apache.kafka.common.metrics.MetricsContext

Returns the labels for this metrics context.

controller() - Method in class org.apache.kafka.clients.admin.DescribeClusterResult

Returns a future which yields the current controller id.

controller() - Method in class org.apache.kafka.common.Cluster

ControllerMovedException - Exception in org.apache.kafka.common.errors

ControllerMovedException(String) - Constructor for exception org.apache.kafka.common.errors.ControllerMovedException

ControllerMovedException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ControllerMovedException

convertToString(Object, ConfigDef.Type) - Static method in class org.apache.kafka.common.config.ConfigDef

convertToStringMapWithPasswordValues(Map<String, ?>) - Static method in class org.apache.kafka.common.config.ConfigDef

Converts a map of config (key, value) pairs to a map of strings where each value is converted to a string.

COOPERATIVE_STICKY_ASSIGNOR_NAME - Static variable in class org.apache.kafka.clients.consumer.CooperativeStickyAssignor

CooperativeStickyAssignor - Class in org.apache.kafka.clients.consumer

A cooperative version of the AbstractStickyAssignor.

CooperativeStickyAssignor() - Constructor for class org.apache.kafka.clients.consumer.CooperativeStickyAssignor

coordinator() - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

The consumer group coordinator, or null if the coordinator is not known.

coordinatorEpoch() - Method in class org.apache.kafka.clients.admin.AbortTransactionSpec

coordinatorEpoch() - Method in class org.apache.kafka.clients.admin.ProducerState

coordinatorId() - Method in class org.apache.kafka.clients.admin.TransactionDescription

CoordinatorLoadInProgressException - Exception in org.apache.kafka.common.errors

In the context of the group coordinator, the broker returns this error code for any coordinator request if it is still loading the group metadata (e.g.

CoordinatorLoadInProgressException(String) - Constructor for exception org.apache.kafka.common.errors.CoordinatorLoadInProgressException

CoordinatorLoadInProgressException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.CoordinatorLoadInProgressException

CoordinatorNotAvailableException - Exception in org.apache.kafka.common.errors

In the context of the group coordinator, the broker returns this error code for metadata or offset commit requests if the group metadata topic has not been created yet.

CoordinatorNotAvailableException(String) - Constructor for exception org.apache.kafka.common.errors.CoordinatorNotAvailableException

CoordinatorNotAvailableException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.CoordinatorNotAvailableException

correlationId() - Method in interface org.apache.kafka.server.authorizer.AuthorizableRequestContext

Returns the correlation id from the request header.

CorruptRecordException - Exception in org.apache.kafka.common.errors

This exception indicates a record has failed its internal CRC check, this generally indicates network or disk corruption.

CorruptRecordException() - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException

CorruptRecordException(String) - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException

CorruptRecordException(Throwable) - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException

CorruptRecordException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException

count() - Method in class org.apache.kafka.clients.consumer.ConsumerRecords

The number of records for all topics

counts() - Method in class org.apache.kafka.common.metrics.stats.Histogram

cpuPercent() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

CPU usage percent.

cpuPercent() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources

Cluster's CPU usage percent.

create(Properties) - Static method in interface org.apache.kafka.clients.admin.Admin

Create a new Admin with the given configuration.

create(Map<String, Object>) - Static method in interface org.apache.kafka.clients.admin.Admin

Create a new Admin with the given configuration.

create(Properties) - Static method in class org.apache.kafka.clients.admin.AdminClient

Create a new Admin with the given configuration.

create(Map<String, Object>) - Static method in class org.apache.kafka.clients.admin.AdminClient

Create a new Admin with the given configuration.

create(Properties) - Static method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Create a new ConfluentAdmin with the given configuration.

create(Map<String, Object>) - Static method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Create a new ConfluentAdmin with the given configuration.

create(Map<String, ?>, Map<String, Object>) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenRetrieverFactory

Create an AccessTokenRetriever from the given SASL and JAAS configuration.

create(Map<String, ?>, String, Map<String, Object>) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenRetrieverFactory

create(Map<String, ?>) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenValidatorFactory

create(Map<String, ?>, String) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenValidatorFactory

create(Map<String, ?>, VerificationKeyResolver) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenValidatorFactory

create(Map<String, ?>, String, VerificationKeyResolver) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.AccessTokenValidatorFactory

create(Map<String, ?>, Map<String, Object>) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.VerificationKeyResolverFactory

Create an AccessTokenRetriever from the given SaslConfigs.

create(Map<String, ?>, String, Map<String, Object>) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.VerificationKeyResolverFactory

createAcls(Collection<AclBinding>) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.createAcls(Collection, CreateAclsOptions) with default options.

createAcls(Collection<AclBinding>, CreateAclsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Creates access control lists (ACLs) which are bound to specific resources.

createAcls(Collection<AclBinding>, CreateAclsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in interface org.apache.kafka.server.authorizer.Authorizer

Creates new ACL bindings.

createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in interface org.apache.kafka.server.authorizer.Authorizer

Confluent extensions to Authorizer API

CreateAclsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.createAcls(Collection).

CreateAclsOptions() - Constructor for class org.apache.kafka.clients.admin.CreateAclsOptions

CreateAclsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.createAcls(Collection) call.

createCentralizedAcls(Collection<AclBinding>, CreateAclsOptions, String, int) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Creates access control lists (ACLs) which are bound to specific resources.

createCentralizedAcls(Collection<AclBinding>, CreateAclsOptions, String, int) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

createClientSslEngine(String, int, String) - Method in interface org.apache.kafka.common.security.auth.SslEngineFactory

Creates a new SSLEngine object to be used by the client.

CreateClusterLinkPolicy - Interface in org.apache.kafka.server.policy

createClusterLinks(Collection<NewClusterLink>, CreateClusterLinksOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Creates links to remote clusters with the specified configurations for performing inter-cluster communications.

createClusterLinks(Collection<NewClusterLink>, CreateClusterLinksOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

CreateClusterLinksOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin.createClusterLinks(Collection, CreateClusterLinksOptions).

CreateClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.CreateClusterLinksOptions

CreateClusterLinksResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.createClusterLinks(Collection, CreateClusterLinksOptions).

CreateClusterLinksResult(Map<String, KafkaFuture<Void>>) - Constructor for class org.apache.kafka.clients.admin.CreateClusterLinksResult

createDelegationToken() - Method in interface org.apache.kafka.clients.admin.Admin

Create a Delegation Token.

createDelegationToken(CreateDelegationTokenOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Create a Delegation Token.

createDelegationToken(CreateDelegationTokenOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

CreateDelegationTokenOptions - Class in org.apache.kafka.clients.admin

Options for Admin.createDelegationToken(CreateDelegationTokenOptions).

CreateDelegationTokenOptions() - Constructor for class org.apache.kafka.clients.admin.CreateDelegationTokenOptions

CreateDelegationTokenResult - Class in org.apache.kafka.clients.admin

The result of the KafkaAdminClient.createDelegationToken(CreateDelegationTokenOptions) call.

createPartitions(Map<String, NewPartitions>) - Method in interface org.apache.kafka.clients.admin.Admin

Increase the number of partitions of the topics given as the keys of newPartitions according to the corresponding values.

createPartitions(Map<String, NewPartitions>, CreatePartitionsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Increase the number of partitions of the topics given as the keys of newPartitions according to the corresponding values.

createPartitions(Map<String, NewPartitions>, CreatePartitionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

CreatePartitionsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.createPartitions(Map).

CreatePartitionsOptions() - Constructor for class org.apache.kafka.clients.admin.CreatePartitionsOptions

CreatePartitionsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.createPartitions(Map) call.

createServerSslEngine(String, int) - Method in interface org.apache.kafka.common.security.auth.SslEngineFactory

Creates a new SSLEngine object to be used by the server.

createSSLSocketFactory() - Method in class org.apache.kafka.common.security.oauthbearer.secured.JaasOptionsUtils

createTimeMs() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

The timestamp at which this broker addition operation was created

createTimeMs() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

The timestamp at which this broker removal operation was created

CreateTopicPolicy - Interface in org.apache.kafka.server.policy

An interface for enforcing a policy on create topics requests.

CreateTopicPolicy.RequestMetadata - Class in org.apache.kafka.server.policy

Class containing the create request parameters.

createTopics(Collection<NewTopic>) - Method in interface org.apache.kafka.clients.admin.Admin

Create a batch of new topics with the default options.

createTopics(Collection<NewTopic>, CreateTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Create a batch of new topics.

createTopics(Collection<NewTopic>, CreateTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

CreateTopicsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.createTopics(Collection).

CreateTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.CreateTopicsOptions

CreateTopicsResult - Class in org.apache.kafka.clients.admin

The result of Admin.createTopics(Collection).

CreateTopicsResult(Map<String, KafkaFuture<CreateTopicsResult.TopicMetadataAndConfig>>) - Constructor for class org.apache.kafka.clients.admin.CreateTopicsResult

CreateTopicsResult.TopicMetadataAndConfig - Class in org.apache.kafka.clients.admin

credentialInfo() - Method in class org.apache.kafka.clients.admin.UserScramCredentialUpsertion

credentialInfos() - Method in class org.apache.kafka.clients.admin.UserScramCredentialsDescription

CumulativeCount - Class in org.apache.kafka.common.metrics.stats

A non-sampled version of WindowedCount maintained over all time.

CumulativeCount() - Constructor for class org.apache.kafka.common.metrics.stats.CumulativeCount

CumulativeSum - Class in org.apache.kafka.common.metrics.stats

An non-sampled cumulative total maintained over all time.

CumulativeSum() - Constructor for class org.apache.kafka.common.metrics.stats.CumulativeSum

CumulativeSum(double) - Constructor for class org.apache.kafka.common.metrics.stats.CumulativeSum

current(long) - Method in class org.apache.kafka.common.metrics.stats.SampledStat

currentEvenClusterLoadStatus() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadStatusDescription

currentLag(TopicPartition) - Method in interface org.apache.kafka.clients.consumer.Consumer

currentLag(TopicPartition) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the consumer's current lag on the partition.

currentLag(TopicPartition) - Method in class org.apache.kafka.clients.consumer.MockConsumer

currentStatusLastUpdatetimeMs() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadStatusDescription

currentTransactionStartOffset() - Method in class org.apache.kafka.clients.admin.ProducerState

D

data() - Method in class org.apache.kafka.common.config.ConfigData

Returns the data.

data() - Method in class org.apache.kafka.common.config.ConfigTransformerResult

Returns the transformed data, with variables replaced with corresponding values from the ConfigProvider instances if found.

deadOrRemovedBrokers() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerRelatedStats

Dead or removed brokers from the cluster.

DEBUG_LOG_LEVEL - Static variable in class org.apache.kafka.common.config.LogLevelConfig

The DEBUG level designates fine-grained informational events that are most useful to debug Kafka

DEFAULT_ALLOW_AUTO_CREATE_TOPICS - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

DEFAULT_API_TIMEOUT_MS_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

DEFAULT_API_TIMEOUT_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

default.api.timeout.ms

DEFAULT_EXCLUDE - Static variable in class org.apache.kafka.common.metrics.JmxReporter

DEFAULT_EXCLUDE_INTERNAL_TOPICS - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

DEFAULT_FETCH_MAX_BYTES - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

DEFAULT_INCLUDE - Static variable in class org.apache.kafka.common.metrics.JmxReporter

DEFAULT_ISOLATION_LEVEL - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

DEFAULT_KERBEROS_KINIT_CMD - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_KERBEROS_MIN_TIME_BEFORE_RELOGIN - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_KERBEROS_TICKET_RENEW_JITTER - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_KERBEROS_TICKET_RENEW_WINDOW_FACTOR - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_LOGIN_REFRESH_BUFFER_SECONDS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_LOGIN_REFRESH_MIN_PERIOD_SECONDS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_LOGIN_REFRESH_WINDOW_FACTOR - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_LOGIN_REFRESH_WINDOW_JITTER - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_MAX_PARTITION_FETCH_BYTES - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

DEFAULT_PATTERN - Static variable in class org.apache.kafka.common.config.ConfigTransformer

DEFAULT_SASL_LOGIN_RETRY_BACKOFF_MAX_MS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_LOGIN_RETRY_BACKOFF_MS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_MECHANISM - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_OAUTHBEARER_CLOCK_SKEW_SECONDS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_OAUTHBEARER_JWKS_ENDPOINT_REFRESH_MS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_OAUTHBEARER_JWKS_ENDPOINT_RETRY_BACKOFF_MAX_MS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_OAUTHBEARER_JWKS_ENDPOINT_RETRY_BACKOFF_MS - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_OAUTHBEARER_SCOPE_CLAIM_NAME - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SASL_OAUTHBEARER_SUB_CLAIM_NAME - Static variable in class org.apache.kafka.common.config.SaslConfigs

DEFAULT_SECURITY_PROTOCOL - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

DEFAULT_SSL_ENABLED_PROTOCOLS - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_ENGINE_FACTORY_CLASS - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_KEYMANGER_ALGORITHM - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_KEYSTORE_TYPE - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_PROTOCOL - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_TRUSTMANAGER_ALGORITHM - Static variable in class org.apache.kafka.common.config.SslConfigs

DEFAULT_SSL_TRUSTSTORE_TYPE - Static variable in class org.apache.kafka.common.config.SslConfigs

defaultValue - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

defaultValues() - Method in class org.apache.kafka.common.config.ConfigDef

define(ConfigDef.ConfigKey) - Method in class org.apache.kafka.common.config.ConfigDef

define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration

define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no custom recommender

define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, ConfigDef.Recommender) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no dependents

define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no dependents and no custom recommender

define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no special validation logic

define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no special validation logic and no custom recommender

define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, ConfigDef.Recommender) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no special validation logic and no custom recommender

define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no special validation logic, not dependents and no custom recommender

define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no default value and no special validation logic

define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no default value, no special validation logic and no custom recommender

define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, ConfigDef.Recommender) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no default value, no special validation logic and no custom recommender

define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no default value, no special validation logic, no dependents and no custom recommender

define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no group, no order in group, no width, no display name, no dependents and no custom recommender

define(String, ConfigDef.Type, Object, ConfigDef.Importance, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no special validation logic

define(String, ConfigDef.Type, ConfigDef.Importance, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new configuration with no default value and no special validation logic

defineBalancerConfigs() - Method in class org.apache.kafka.common.config.ConfigDef

defineInternal(String, ConfigDef.Type, Object, ConfigDef.Importance) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new internal configuration.

defineInternal(String, ConfigDef.Type, Object, ConfigDef.Importance, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new internal configuration.

defineInternal(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String) - Method in class org.apache.kafka.common.config.ConfigDef

Define a new internal configuration.

DelegatingReconfigurable - Class in org.apache.kafka.common

DelegatingReconfigurable(Supplier<?>) - Constructor for class org.apache.kafka.common.DelegatingReconfigurable

delegationToken() - Method in class org.apache.kafka.clients.admin.CreateDelegationTokenResult

Returns a future which yields a delegation token

DelegationToken - Class in org.apache.kafka.common.security.token.delegation

A class representing a delegation token.

DelegationToken(TokenInformation, byte[]) - Constructor for class org.apache.kafka.common.security.token.delegation.DelegationToken

DelegationTokenAuthorizationException - Exception in org.apache.kafka.common.errors

DelegationTokenAuthorizationException(String) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenAuthorizationException

DelegationTokenAuthorizationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenAuthorizationException

DelegationTokenDisabledException - Exception in org.apache.kafka.common.errors

DelegationTokenDisabledException(String) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenDisabledException

DelegationTokenDisabledException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenDisabledException

DelegationTokenExpiredException - Exception in org.apache.kafka.common.errors

DelegationTokenExpiredException(String) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenExpiredException

DelegationTokenExpiredException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenExpiredException

DelegationTokenNotFoundException - Exception in org.apache.kafka.common.errors

DelegationTokenNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenNotFoundException

DelegationTokenNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenNotFoundException

DelegationTokenOwnerMismatchException - Exception in org.apache.kafka.common.errors

DelegationTokenOwnerMismatchException(String) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException

DelegationTokenOwnerMismatchException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException

delegationTokens() - Method in class org.apache.kafka.clients.admin.DescribeDelegationTokenResult

Returns a future which yields list of delegation tokens

DELETE_RETENTION_MS_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

DELETE_RETENTION_MS_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

deleteAcls(Collection<AclBindingFilter>) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.deleteAcls(Collection, DeleteAclsOptions) with default options.

deleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Deletes access control lists (ACLs) according to the supplied filters.

deleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in interface org.apache.kafka.server.authorizer.Authorizer

Deletes all ACL bindings that match the provided filters.

deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>) - Method in interface org.apache.kafka.server.authorizer.Authorizer

DeleteAclsOptions - Class in org.apache.kafka.clients.admin

Options for the Admin.deleteAcls(Collection) call.

DeleteAclsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteAclsOptions

DeleteAclsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.deleteAcls(Collection) call.

DeleteAclsResult.FilterResult - Class in org.apache.kafka.clients.admin

A class containing either the deleted ACL binding or an exception if the delete failed.

DeleteAclsResult.FilterResults - Class in org.apache.kafka.clients.admin

A class containing the results of the delete ACLs operation.

deleteCentralizedAcls(Collection<AclBindingFilter>, DeleteAclsOptions, String, int) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Deletes access control lists (ACLs) according to the supplied filters.

deleteCentralizedAcls(Collection<AclBindingFilter>, DeleteAclsOptions, String, int) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

deleteClusterLinks(Collection<String>, DeleteClusterLinksOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Deletes established links to remote clusters with the provided link names.

deleteClusterLinks(Collection<String>, DeleteClusterLinksOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DeleteClusterLinksOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin.deleteClusterLinks(Collection, DeleteClusterLinksOptions).

DeleteClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteClusterLinksOptions

DeleteClusterLinksResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.deleteClusterLinks(Collection, DeleteClusterLinksOptions).

DeleteClusterLinksResult(Map<String, KafkaFuture<Void>>) - Constructor for class org.apache.kafka.clients.admin.DeleteClusterLinksResult

deleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Delete committed offsets for a set of partitions in a consumer group.

deleteConsumerGroupOffsets(String, Set<TopicPartition>) - Method in interface org.apache.kafka.clients.admin.Admin

Delete committed offsets for a set of partitions in a consumer group with the default options.

deleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DeleteConsumerGroupOffsetsOptions - Class in org.apache.kafka.clients.admin

Options for the Admin.deleteConsumerGroupOffsets(String, Set) call.

DeleteConsumerGroupOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsOptions

DeleteConsumerGroupOffsetsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.deleteConsumerGroupOffsets(String, Set) call.

deleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Delete consumer groups from the cluster.

deleteConsumerGroups(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin

Delete consumer groups from the cluster with the default options.

deleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DeleteConsumerGroupsOptions - Class in org.apache.kafka.clients.admin

Options for the Admin.deleteConsumerGroups(Collection) call.

DeleteConsumerGroupsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions

DeleteConsumerGroupsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.deleteConsumerGroups(Collection) call.

deletedGroups() - Method in class org.apache.kafka.clients.admin.DeleteConsumerGroupsResult

Return a map from group id to futures which can be used to check the status of individual deletions.

DeletedRecords - Class in org.apache.kafka.clients.admin

Represents information about deleted records The API for this class is still evolving and we may break compatibility in minor releases, if necessary.

DeletedRecords(long) - Constructor for class org.apache.kafka.clients.admin.DeletedRecords

Create an instance of this class with the provided parameters.

deleteRecords(Map<TopicPartition, RecordsToDelete>) - Method in interface org.apache.kafka.clients.admin.Admin

Delete records whose offset is smaller than the given offset of the corresponding partition.

deleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Delete records whose offset is smaller than the given offset of the corresponding partition.

deleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DeleteRecordsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.deleteRecords(Map, DeleteRecordsOptions).

DeleteRecordsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteRecordsOptions

DeleteRecordsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.deleteRecords(Map) call.

DeleteRecordsResult(Map<TopicPartition, KafkaFuture<DeletedRecords>>) - Constructor for class org.apache.kafka.clients.admin.DeleteRecordsResult

deleteTopics(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.deleteTopics(TopicCollection, DeleteTopicsOptions) with default options.

deleteTopics(Collection<String>, DeleteTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.deleteTopics(TopicCollection, DeleteTopicsOptions) with default options.

deleteTopics(TopicCollection) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.deleteTopics(TopicCollection, DeleteTopicsOptions) with default options.

deleteTopics(TopicCollection, DeleteTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Delete a batch of topics.

deleteTopics(TopicCollection, DeleteTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DeleteTopicsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.deleteTopics(Collection).

DeleteTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteTopicsOptions

DeleteTopicsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.deleteTopics(Collection) call.

DeleteTopicsResult(Map<Uuid, KafkaFuture<Void>>, Map<String, KafkaFuture<Void>>) - Constructor for class org.apache.kafka.clients.admin.DeleteTopicsResult

DELIVERY_TIMEOUT_MS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

delivery.timeout.ms

DemotedBroker - Class in org.apache.kafka.clients.admin

DemotedBroker(int, List<String>) - Constructor for class org.apache.kafka.clients.admin.DemotedBroker

DemotionLimitReachedException - Exception in org.apache.kafka.common.errors

DemotionLimitReachedException(String) - Constructor for exception org.apache.kafka.common.errors.DemotionLimitReachedException

dependents - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

describeAcls(AclBindingFilter) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.describeAcls(AclBindingFilter, DescribeAclsOptions) with default options.

describeAcls(AclBindingFilter, DescribeAclsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Lists access control lists (ACLs) according to the supplied filter.

describeAcls(AclBindingFilter, DescribeAclsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeAclsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeAcls(AclBindingFilter).

DescribeAclsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeAclsOptions

DescribeAclsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeAcls(AclBindingFilter) call.

DescribeAclsResult(KafkaFuture<Collection<AclBinding>>) - Constructor for class org.apache.kafka.clients.admin.DescribeAclsResult

describeBalancerStatus() - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes status of Confluent Balancer component.

describeBalancerStatus(DescribeBalancerStatusOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes status of confluent balancer component.

describeBalancerStatus(DescribeBalancerStatusOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeBalancerStatusOptions - Class in org.apache.kafka.clients.admin

The options to use when fetching the balancer status.

DescribeBalancerStatusOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeBalancerStatusOptions

DescribeBalancerStatusResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeBalancerStatus(DescribeBalancerStatusOptions).

describeBrokerAdditions() - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes all the broker additions in the cluster.

describeBrokerAdditions(DescribeBrokerAdditionsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes all the broker additions in the cluster.

describeBrokerAdditions(DescribeBrokerAdditionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeBrokerAdditionsOptions - Class in org.apache.kafka.clients.admin

DescribeBrokerAdditionsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeBrokerAdditionsOptions

DescribeBrokerAdditionsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeBrokerAdditions(DescribeBrokerAdditionsOptions).

describeBrokerRemovals() - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes all the broker removals in the cluster.

describeBrokerRemovals(DescribeBrokerRemovalsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes all the broker removals in the cluster.

describeBrokerRemovals(DescribeBrokerRemovalsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeBrokerRemovalsOptions - Class in org.apache.kafka.clients.admin

DescribeBrokerRemovalsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeBrokerRemovalsOptions

DescribeBrokerRemovalsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeBrokerRemovals(DescribeBrokerRemovalsOptions).

describeBrokerReplicaExclusions(DescribeBrokerReplicaExclusionsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes the active broker replica exclusions in the cluster.

describeBrokerReplicaExclusions() - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes the active broker replica exclusions in the cluster.

describeBrokerReplicaExclusions(DescribeBrokerReplicaExclusionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeBrokerReplicaExclusionsOptions - Class in org.apache.kafka.clients.admin

DescribeBrokerReplicaExclusionsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeBrokerReplicaExclusionsOptions

DescribeBrokerReplicaExclusionsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeBrokerReplicaExclusions(DescribeBrokerReplicaExclusionsOptions).

DescribeBrokerReplicaExclusionsResult(KafkaFuture<List<DescribeBrokerReplicaExclusionsResult.BrokerReplicaExclusionDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeBrokerReplicaExclusionsResult

DescribeBrokerReplicaExclusionsResult.BrokerReplicaExclusionDescription - Class in org.apache.kafka.clients.admin

A description of a broker replica exclusion for the given broker brokerId with the associated reason for the exclusion.

describeClientQuotas(ClientQuotaFilter) - Method in interface org.apache.kafka.clients.admin.Admin

Describes all entities matching the provided filter that have at least one client quota configuration value defined.

describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describes all entities matching the provided filter that have at least one client quota configuration value defined.

describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeClientQuotasOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions).

DescribeClientQuotasOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeClientQuotasOptions

DescribeClientQuotasResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) call.

DescribeClientQuotasResult(KafkaFuture<Map<ClientQuotaEntity, Map<String, Double>>>) - Constructor for class org.apache.kafka.clients.admin.DescribeClientQuotasResult

Maps an entity to its configured quota value(s).

describeCluster() - Method in interface org.apache.kafka.clients.admin.Admin

Get information about the nodes in the cluster, using the default options.

describeCluster(DescribeClusterOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Get information about the nodes in the cluster.

describeCluster(DescribeClusterOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

describeClusterLinks(DescribeClusterLinksOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describe the cluster links.

describeClusterLinks(DescribeClusterLinksOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeClusterLinksOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin.describeClusterLinks(DescribeClusterLinksOptions).

DescribeClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeClusterLinksOptions

DescribeClusterLinksResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeClusterLinks(DescribeClusterLinksOptions).

DescribeClusterLinksResult(KafkaFuture<Collection<ClusterLinkDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeClusterLinksResult

DescribeClusterOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeCluster().

DescribeClusterOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeClusterOptions

DescribeClusterResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeCluster() call.

describeConfigs(Collection<ConfigResource>) - Method in interface org.apache.kafka.clients.admin.Admin

Get the configuration for the specified resources with the default options.

describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Get the configuration for the specified resources.

describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeConfigsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeConfigs(Collection).

DescribeConfigsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeConfigsOptions

DescribeConfigsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeConfigs(Collection) call.

DescribeConfigsResult(Map<ConfigResource, KafkaFuture<Config>>) - Constructor for class org.apache.kafka.clients.admin.DescribeConfigsResult

describeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe some group IDs in the cluster.

describeConsumerGroups(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin

Describe some group IDs in the cluster, with the default options.

describeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeConsumerGroupsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeConsumerGroups(Collection, DescribeConsumerGroupsOptions).

DescribeConsumerGroupsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions

DescribeConsumerGroupsResult - Class in org.apache.kafka.clients.admin

The result of the KafkaAdminClient.describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)} call.

DescribeConsumerGroupsResult(Map<String, KafkaFuture<ConsumerGroupDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeConsumerGroupsResult

describeDelegationToken() - Method in interface org.apache.kafka.clients.admin.Admin

Describe the Delegation Tokens.

describeDelegationToken(DescribeDelegationTokenOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe the Delegation Tokens.

describeDelegationToken(DescribeDelegationTokenOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeDelegationTokenOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeDelegationToken(DescribeDelegationTokenOptions).

DescribeDelegationTokenOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeDelegationTokenOptions

DescribeDelegationTokenResult - Class in org.apache.kafka.clients.admin

The result of the KafkaAdminClient.describeDelegationToken(DescribeDelegationTokenOptions) call.

describedGroups() - Method in class org.apache.kafka.clients.admin.DescribeConsumerGroupsResult

Return a map from group id to futures which yield group descriptions.

describeEvenClusterLoadStatus() - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describe the status of the even cluster load operation.

describeEvenClusterLoadStatus(DescribeEvenClusterLoadStatusOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describe the status of the even cluster load operation.

describeEvenClusterLoadStatus(DescribeEvenClusterLoadStatusOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeEvenClusterLoadStatusOptions - Class in org.apache.kafka.clients.admin

The options to use when fetching the even cluster load status.

DescribeEvenClusterLoadStatusOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeEvenClusterLoadStatusOptions

DescribeEvenClusterLoadStatusResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeEvenClusterLoadStatus(DescribeEvenClusterLoadStatusOptions).

describeFeatures() - Method in interface org.apache.kafka.clients.admin.Admin

Describes finalized as well as supported features.

describeFeatures(DescribeFeaturesOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describes finalized as well as supported features.

describeFeatures(DescribeFeaturesOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeFeaturesOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeFeatures(DescribeFeaturesOptions).

DescribeFeaturesOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeFeaturesOptions

DescribeFeaturesResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeFeatures(DescribeFeaturesOptions) call.

describeLeadershipPriority(DescribeLeadershipPriorityOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describe all brokers with demoted leadership priority and their list of reasons for demotion.

describeLeadershipPriority(DescribeLeadershipPriorityOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeLeadershipPriorityOptions - Class in org.apache.kafka.clients.admin

DescribeLeadershipPriorityOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeLeadershipPriorityOptions

DescribeLeadershipPriorityResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeLeadershipPriority(DescribeLeadershipPriorityOptions) .

describeLogDirs(Collection<Integer>) - Method in interface org.apache.kafka.clients.admin.Admin

Query the information of all log directories on the given set of brokers

describeLogDirs(Collection<Integer>, DescribeLogDirsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Query the information of all log directories on the given set of brokers

describeLogDirs(Collection<Integer>, DescribeLogDirsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeLogDirsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeLogDirs(Collection) The API of this class is evolving, see Admin for details.

DescribeLogDirsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeLogDirsOptions

DescribeLogDirsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeLogDirs(Collection) call.

describeMetadataQuorum() - Method in interface org.apache.kafka.clients.admin.Admin

Describes the state of the metadata quorum.

describeMetadataQuorum(DescribeMetadataQuorumOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describes the state of the metadata quorum.

describeMetadataQuorum(DescribeMetadataQuorumOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeMetadataQuorumOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeMetadataQuorum(DescribeMetadataQuorumOptions)

DescribeMetadataQuorumOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeMetadataQuorumOptions

DescribeMetadataQuorumResult - Class in org.apache.kafka.clients.admin

The result of Admin.describeMetadataQuorum(DescribeMetadataQuorumOptions)

describeMirrors(Collection<String>, DescribeMirrorsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Describes the state of mirrored topics, i.e.

describeMirrors(Collection<String>, DescribeMirrorsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeMirrorsOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin.describeMirrors(Collection, DescribeMirrorsOptions).

DescribeMirrorsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeMirrorsOptions

DescribeMirrorsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.describeMirrors(Collection, DescribeMirrorsOptions).

DescribeMirrorsResult(Map<String, KafkaFuture<MirrorTopicDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeMirrorsResult

describeProducers(Collection<TopicPartition>) - Method in interface org.apache.kafka.clients.admin.Admin

Describe producer state on a set of topic partitions.

describeProducers(Collection<TopicPartition>, DescribeProducersOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe active producer state on a set of topic partitions.

describeProducers(Collection<TopicPartition>, DescribeProducersOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeProducersOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeProducers(Collection).

DescribeProducersOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeProducersOptions

DescribeProducersResult - Class in org.apache.kafka.clients.admin

DescribeProducersResult.PartitionProducerState - Class in org.apache.kafka.clients.admin

describeReplicaLogDirs(Collection<TopicPartitionReplica>) - Method in interface org.apache.kafka.clients.admin.Admin

Query the replica log directory information for the specified replicas.

describeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Query the replica log directory information for the specified replicas.

describeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeReplicaLogDirsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeReplicaLogDirs(Collection).

DescribeReplicaLogDirsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions

DescribeReplicaLogDirsResult - Class in org.apache.kafka.clients.admin

The result of Admin.describeReplicaLogDirs(Collection).

DescribeReplicaLogDirsResult.ReplicaLogDirInfo - Class in org.apache.kafka.clients.admin

describeTopics(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin

Describe some topics in the cluster, with the default options.

describeTopics(Collection<String>, DescribeTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe some topics in the cluster.

describeTopics(TopicCollection) - Method in interface org.apache.kafka.clients.admin.Admin

This is a convenience method for Admin.describeTopics(TopicCollection, DescribeTopicsOptions) with default options.

describeTopics(TopicCollection, DescribeTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe some topics in the cluster.

describeTopics(TopicCollection, DescribeTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeTopicsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeTopics(Collection).

DescribeTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeTopicsOptions

DescribeTopicsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeTopics(Collection) call.

DescribeTopicsResult(Map<String, KafkaFuture<TopicDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeTopicsResult

Deprecated.

DescribeTopicsResult(Map<Uuid, KafkaFuture<TopicDescription>>, Map<String, KafkaFuture<TopicDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeTopicsResult

describeTransactions(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin

Describe the state of a set of transactional IDs.

describeTransactions(Collection<String>, DescribeTransactionsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe the state of a set of transactional IDs from the respective transaction coordinators, which are dynamically discovered.

describeTransactions(Collection<String>, DescribeTransactionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeTransactionsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeTransactions(Collection).

DescribeTransactionsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeTransactionsOptions

DescribeTransactionsResult - Class in org.apache.kafka.clients.admin

describeUserScramCredentials() - Method in interface org.apache.kafka.clients.admin.Admin

Describe all SASL/SCRAM credentials.

describeUserScramCredentials(List<String>) - Method in interface org.apache.kafka.clients.admin.Admin

Describe SASL/SCRAM credentials for the given users.

describeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Describe SASL/SCRAM credentials.

describeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

DescribeUserScramCredentialsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.describeUserScramCredentials(List, DescribeUserScramCredentialsOptions) The API of this class is evolving.

DescribeUserScramCredentialsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeUserScramCredentialsOptions

DescribeUserScramCredentialsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.describeUserScramCredentials() call.

description() - Method in class org.apache.kafka.clients.admin.DescribeBalancerStatusResult

Return the future which can be used to check the status of the balancer.

description(int) - Method in class org.apache.kafka.clients.admin.DescribeBrokerAdditionsResult

Return a future of an optional broker addition description for the provided #brokerId

description(int) - Method in class org.apache.kafka.clients.admin.DescribeBrokerRemovalsResult

Return a future of an optional broker removal description for the provided #brokerId

description() - Method in class org.apache.kafka.clients.admin.DescribeEvenClusterLoadStatusResult

Return the future which can be uses to check the status of the even cluster load task.

description(String) - Method in class org.apache.kafka.clients.admin.DescribeTransactionsResult

Get the description of a specific transactional ID.

description(String) - Method in class org.apache.kafka.clients.admin.DescribeUserScramCredentialsResult

description() - Method in class org.apache.kafka.common.MetricName

description() - Method in class org.apache.kafka.common.MetricNameTemplate

Get the description of the metric.

descriptions() - Method in class org.apache.kafka.clients.admin.DescribeBrokerAdditionsResult

Return a future of a map of broker ids to descriptions which can be used to check the status of individual broker additions.

descriptions() - Method in class org.apache.kafka.clients.admin.DescribeBrokerRemovalsResult

Return a map of broker ids to futures which can be used to check the status of individual broker removals.

descriptions() - Method in class org.apache.kafka.clients.admin.DescribeBrokerReplicaExclusionsResult

Return a single future denoting the IDs of the brokers which are excluded from having replicas placed on them.

descriptions() - Method in class org.apache.kafka.clients.admin.DescribeLogDirsResult

Return a map from brokerId to future which can be used to check the information of partitions on each individual broker.

deserialize(byte[]) - Method in interface org.apache.kafka.common.security.auth.KafkaPrincipalSerde

Deserialize a KafkaPrincipal from byte array.

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.ByteArrayDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.ByteBufferDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.BytesDeserializer

deserialize(String, byte[]) - Method in interface org.apache.kafka.common.serialization.Deserializer

Deserialize a record value from a byte array into a value or object.

deserialize(String, Headers, byte[]) - Method in interface org.apache.kafka.common.serialization.Deserializer

Deserialize a record value from a byte array into a value or object.

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.DoubleDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.FloatDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.IntegerDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.ListDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.LongDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.ShortDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.StringDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.UUIDDeserializer

deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.VoidDeserializer

Deserializer<T> - Interface in org.apache.kafka.common.serialization

An interface for converting bytes to objects.

deserializer() - Method in interface org.apache.kafka.common.serialization.Serde

deserializer() - Method in class org.apache.kafka.common.serialization.Serdes.WrapperSerde

DESTINATION - Static variable in interface org.apache.kafka.server.policy.CreateClusterLinkPolicy

DirectoryConfigProvider - Class in org.apache.kafka.common.config.provider

An implementation of ConfigProvider based on a directory of files.

DirectoryConfigProvider() - Constructor for class org.apache.kafka.common.config.provider.DirectoryConfigProvider

DisconnectException - Exception in org.apache.kafka.common.errors

Server disconnected before a request could be completed.

DisconnectException() - Constructor for exception org.apache.kafka.common.errors.DisconnectException

DisconnectException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DisconnectException

DisconnectException(String) - Constructor for exception org.apache.kafka.common.errors.DisconnectException

DisconnectException(Throwable) - Constructor for exception org.apache.kafka.common.errors.DisconnectException

diskMB() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Disk usage in MB.

diskMB() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources

Cluster's disk usage in MB.

diskPercent() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Percentage of used up disk.

displayName - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

divergentOffsets() - Method in exception org.apache.kafka.clients.consumer.LogTruncationException

Get the divergent offsets for the partitions which were truncated.

documentation() - Method in class org.apache.kafka.clients.admin.ConfigEntry

Return the config documentation.

documentation - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

documentationOf(String) - Method in class org.apache.kafka.common.config.AbstractConfig

Double() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable Double type.

DoubleDeserializer - Class in org.apache.kafka.common.serialization

DoubleDeserializer() - Constructor for class org.apache.kafka.common.serialization.DoubleDeserializer

DoubleSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.DoubleSerde

DoubleSerializer - Class in org.apache.kafka.common.serialization

DoubleSerializer() - Constructor for class org.apache.kafka.common.serialization.DoubleSerializer

dryRun() - Method in class org.apache.kafka.clients.admin.UpdateFeaturesOptions

Deprecated.

dryRun(boolean) - Method in class org.apache.kafka.clients.admin.UpdateFeaturesOptions

Deprecated.

DuplicateBrokerRegistrationException - Exception in org.apache.kafka.common.errors

DuplicateBrokerRegistrationException(String) - Constructor for exception org.apache.kafka.common.errors.DuplicateBrokerRegistrationException

DuplicateBrokerRegistrationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DuplicateBrokerRegistrationException

DuplicateResourceException - Exception in org.apache.kafka.common.errors

Exception thrown due to a request that illegally refers to the same resource twice (for example, trying to both create and delete the same SCRAM credential for a particular user in a single request).

DuplicateResourceException(String) - Constructor for exception org.apache.kafka.common.errors.DuplicateResourceException

Constructor

DuplicateResourceException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DuplicateResourceException

DuplicateResourceException(String, String) - Constructor for exception org.apache.kafka.common.errors.DuplicateResourceException

Constructor

DuplicateResourceException(String, String, Throwable) - Constructor for exception org.apache.kafka.common.errors.DuplicateResourceException

Constructor

DuplicateSequenceException - Exception in org.apache.kafka.common.errors

DuplicateSequenceException(String) - Constructor for exception org.apache.kafka.common.errors.DuplicateSequenceException

E

earliest() - Static method in class org.apache.kafka.clients.admin.OffsetSpec

Used to retrieve the earliest offset of a partition

EarliestSpec() - Constructor for class org.apache.kafka.clients.admin.OffsetSpec.EarliestSpec

earlyStartListeners() - Method in interface org.apache.kafka.server.authorizer.AuthorizerServerInfo

Returns the configured early start listeners.

ElectionNotNeededException - Exception in org.apache.kafka.common.errors

ElectionNotNeededException(String) - Constructor for exception org.apache.kafka.common.errors.ElectionNotNeededException

ElectionNotNeededException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ElectionNotNeededException

ElectionType - Enum in org.apache.kafka.common

Options for Admin.electLeaders(ElectionType, Set, org.apache.kafka.clients.admin.ElectLeadersOptions).

electLeaders(ElectionType, Set<TopicPartition>) - Method in interface org.apache.kafka.clients.admin.Admin

Elect a replica as leader for topic partitions.

electLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Elect a replica as leader for the given partitions, or for all partitions if the argument to partitions is null.

electLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ElectLeadersOptions - Class in org.apache.kafka.clients.admin

Options for Admin.electLeaders(ElectionType, Set, ElectLeadersOptions).

ElectLeadersOptions() - Constructor for class org.apache.kafka.clients.admin.ElectLeadersOptions

ElectLeadersResult - Class in org.apache.kafka.clients.admin

The result of Admin.electLeaders(ElectionType, Set, ElectLeadersOptions) The API of this class is evolving, see Admin for details.

EligibleLeadersNotAvailableException - Exception in org.apache.kafka.common.errors

EligibleLeadersNotAvailableException(String) - Constructor for exception org.apache.kafka.common.errors.EligibleLeadersNotAvailableException

EligibleLeadersNotAvailableException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.EligibleLeadersNotAvailableException

embed(String, String, int, ConfigDef) - Method in class org.apache.kafka.common.config.ConfigDef

EMPTY - Static variable in class org.apache.kafka.clients.consumer.ConsumerRecords

empty() - Static method in class org.apache.kafka.clients.consumer.ConsumerRecords

empty() - Static method in class org.apache.kafka.common.Cluster

Create an empty cluster instance with no nodes and no topic-partitions.

empty() - Static method in class org.apache.kafka.common.security.auth.SaslExtensions

Creates an "empty" instance indicating no SASL extensions.

ENABLE_AUTO_COMMIT_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

enable.auto.commit

ENABLE_IDEMPOTENCE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

enable.idempotence

ENABLE_IDEMPOTENCE_DOC - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

enableDynamicQuota(boolean) - Method in interface org.apache.kafka.server.quota.ClientQuotaCallback

Enable or Disable returning dynamic quotas as configured by updateDynamicQuotas().

endOffsets(Collection<TopicPartition>) - Method in interface org.apache.kafka.clients.consumer.Consumer

endOffsets(Collection<TopicPartition>, Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

endOffsets(Collection<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the end offsets for the given partitions.

endOffsets(Collection<TopicPartition>, Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the end offsets for the given partitions.

endOffsets(Collection<TopicPartition>) - Method in class org.apache.kafka.clients.consumer.MockConsumer

endOffsets(Collection<TopicPartition>, Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

Endpoint - Class in org.apache.kafka.common

Represents a broker endpoint.

Endpoint(String, SecurityProtocol, String, int) - Constructor for class org.apache.kafka.common.Endpoint

endpoints() - Method in interface org.apache.kafka.server.authorizer.AuthorizerServerInfo

Returns endpoints for all listeners including the advertised host and port to which the listener is bound.

enforceRebalance() - Method in interface org.apache.kafka.clients.consumer.Consumer

enforceRebalance(String) - Method in interface org.apache.kafka.clients.consumer.Consumer

enforceRebalance(String) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Alert the consumer to trigger a new rebalance by rejoining the group.

enforceRebalance() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

enforceRebalance() - Method in class org.apache.kafka.clients.consumer.MockConsumer

enforceRebalance(String) - Method in class org.apache.kafka.clients.consumer.MockConsumer

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.CaseInsensitiveValidString

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.CompositeValidator

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.ConcreteSubClassValidator

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.InstantiableClassValidator

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.LambdaValidator

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.ListSize

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.NonEmptyString

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.NonEmptyStringWithoutControlChars

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.NonNullValidator

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.Range

ensureValid(String, Object) - Method in interface org.apache.kafka.common.config.ConfigDef.Validator

Perform single configuration validation.

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.ValidList

ensureValid(String, Object) - Method in class org.apache.kafka.common.config.ConfigDef.ValidString

entities() - Method in class org.apache.kafka.clients.admin.DescribeClientQuotasResult

Returns a map from quota entity to a future which can be used to check the status of the operation.

entity() - Method in class org.apache.kafka.common.quota.ClientQuotaAlteration

entityType() - Method in class org.apache.kafka.common.quota.ClientQuotaFilterComponent

entityType() - Method in interface org.apache.kafka.server.quota.ClientQuotaEntity.ConfigEntity

Returns the type of this entity.

entries() - Method in class org.apache.kafka.clients.admin.Config

Configuration entries for a resource.

entries() - Method in class org.apache.kafka.common.quota.ClientQuotaEntity

entry() - Method in class org.apache.kafka.common.acl.AclBinding

entryFilter() - Method in class org.apache.kafka.common.acl.AclBindingFilter

epochId(String) - Method in class org.apache.kafka.clients.admin.FenceProducersResult

Returns a future that provides the epoch ID generated while initializing the given transaction when the request completes.

equals(Object) - Method in class org.apache.kafka.clients.admin.AbortTransactionSpec

equals(Object) - Method in class org.apache.kafka.clients.admin.AlterConfigOp

equals(Object) - Method in class org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec

equals(Object) - Method in class org.apache.kafka.clients.admin.BalancerOperationError

equals(Object) - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

equals(Object) - Method in class org.apache.kafka.clients.admin.Config

equals(Object) - Method in class org.apache.kafka.clients.admin.ConfigEntry.ConfigSynonym

equals(Object) - Method in class org.apache.kafka.clients.admin.ConfigEntry

equals(Object) - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.ConsumerGroupListing

equals(Object) - Method in class org.apache.kafka.clients.admin.DescribeProducersOptions

equals(Object) - Method in class org.apache.kafka.clients.admin.ExclusionOp

equals(Object) - Method in class org.apache.kafka.clients.admin.FeatureMetadata

equals(Object) - Method in class org.apache.kafka.clients.admin.FeatureUpdate

equals(Object) - Method in class org.apache.kafka.clients.admin.FinalizedVersionRange

equals(Object) - Method in class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsSpec

equals(Object) - Method in class org.apache.kafka.clients.admin.ListTopicsOptions

equals(Object) - Method in class org.apache.kafka.clients.admin.ListTransactionsOptions

equals(Object) - Method in class org.apache.kafka.clients.admin.MemberAssignment

equals(Object) - Method in class org.apache.kafka.clients.admin.MemberDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.MemberToRemove

equals(Object) - Method in class org.apache.kafka.clients.admin.MirrorTopicDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.NewClusterLink

equals(Object) - Method in class org.apache.kafka.clients.admin.NewMirrorTopic

equals(Object) - Method in class org.apache.kafka.clients.admin.NewTopic

equals(Object) - Method in class org.apache.kafka.clients.admin.ProducerState

equals(Object) - Method in class org.apache.kafka.clients.admin.QuorumInfo

equals(Object) - Method in class org.apache.kafka.clients.admin.QuorumInfo.ReplicaState

equals(Object) - Method in class org.apache.kafka.clients.admin.RecordsToDelete

equals(Object) - Method in class org.apache.kafka.clients.admin.ScramCredentialInfo

equals(Object) - Method in class org.apache.kafka.clients.admin.SupportedVersionRange

equals(Object) - Method in class org.apache.kafka.clients.admin.TopicDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.TransactionDescription

equals(Object) - Method in class org.apache.kafka.clients.admin.TransactionListing

equals(Object) - Method in class org.apache.kafka.clients.admin.UserScramCredentialsDescription

equals(Object) - Method in class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

equals(Object) - Method in class org.apache.kafka.clients.consumer.OffsetAndMetadata

equals(Object) - Method in class org.apache.kafka.clients.consumer.OffsetAndTimestamp

equals(Object) - Method in class org.apache.kafka.clients.producer.ProducerRecord

equals(Object) - Method in class org.apache.kafka.common.acl.AccessControlEntry

equals(Object) - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

equals(Object) - Method in class org.apache.kafka.common.acl.AclBinding

equals(Object) - Method in class org.apache.kafka.common.acl.AclBindingFilter

equals(Object) - Method in class org.apache.kafka.common.Cluster

equals(Object) - Method in class org.apache.kafka.common.ClusterResource

equals(Object) - Method in class org.apache.kafka.common.config.AbstractConfig

equals(Object) - Method in class org.apache.kafka.common.config.ConfigResource

equals(Object) - Method in class org.apache.kafka.common.config.ConfigValue

equals(Object) - Method in class org.apache.kafka.common.Endpoint

equals(Object) - Method in class org.apache.kafka.common.MetricName

equals(Object) - Method in class org.apache.kafka.common.MetricNameTemplate

equals(Object) - Method in class org.apache.kafka.common.metrics.Quota

equals(Object) - Method in class org.apache.kafka.common.Node

equals(Object) - Method in class org.apache.kafka.common.quota.ClientQuotaAlteration.Op

equals(Object) - Method in class org.apache.kafka.common.quota.ClientQuotaEntity

equals(Object) - Method in class org.apache.kafka.common.quota.ClientQuotaFilter

equals(Object) - Method in class org.apache.kafka.common.quota.ClientQuotaFilterComponent

equals(Object) - Method in class org.apache.kafka.common.resource.Resource

equals(Object) - Method in class org.apache.kafka.common.resource.ResourcePattern

equals(Object) - Method in class org.apache.kafka.common.resource.ResourcePatternFilter

equals(Object) - Method in class org.apache.kafka.common.security.auth.KafkaPrincipal

equals(Object) - Method in class org.apache.kafka.common.security.auth.SaslExtensions

Implements equals using the reference comparison implementation from Object.equals(Object).

equals(Object) - Method in class org.apache.kafka.common.security.token.delegation.DelegationToken

equals(Object) - Method in class org.apache.kafka.common.security.token.delegation.TokenInformation

equals(Object) - Method in class org.apache.kafka.common.TopicIdPartition

equals(Object) - Method in class org.apache.kafka.common.TopicPartition

equals(Object) - Method in class org.apache.kafka.common.TopicPartitionInfo

equals(Object) - Method in class org.apache.kafka.common.TopicPartitionReplica

equals(Object) - Method in class org.apache.kafka.common.Uuid

Returns true iff obj is another Uuid represented by the same two long values.

equals(Object) - Method in class org.apache.kafka.server.authorizer.Action

equals(Object) - Method in class org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata

equals(Object) - Method in class org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata

error() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

The error that failed the broker removal operation.

error() - Method in class org.apache.kafka.clients.admin.LogDirDescription

Returns `ApiException` if the log directory is offline or an error occurred, otherwise returns null.

error(String, String) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback

Set the error value for a specific extension key-value pair if validation has failed

error(String, String, String) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback

Set the error values as per RFC 6749: The OAuth 2.0 Authorization Framework.

error(String, String, String) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback

Set the error values as per RFC 7628: A Set of Simple Authentication and Security Layer (SASL) Mechanisms for OAuth.

ERROR_LOG_LEVEL - Static variable in class org.apache.kafka.common.config.LogLevelConfig

The ERROR level designates error events that might still allow the broker to continue running.

errorCode() - Method in class org.apache.kafka.clients.admin.BalancerOperationError

errorCode() - Method in class org.apache.kafka.clients.admin.ExclusionOperationError

errorCode() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback

Return the optional (but always non-empty if not null) error code as per RFC 6749: The OAuth 2.0 Authorization Framework.

errorDescription() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback

Return the (potentially null) error description as per RFC 6749: The OAuth 2.0 Authorization Framework.

errorInfo() - Method in exception org.apache.kafka.common.errors.AuthenticationException

errorMessage() - Method in class org.apache.kafka.clients.admin.BalancerOperationError

errorMessage() - Method in class org.apache.kafka.clients.admin.ExclusionOperationError

errorMessage() - Method in exception org.apache.kafka.common.errors.AuthenticationException

This message is for internal logging/auditing and should not be returned to clients.

errorMessage() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback

errorMessage(String) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback

errorMessages() - Method in class org.apache.kafka.common.config.ConfigValue

errorNext(RuntimeException) - Method in class org.apache.kafka.clients.producer.MockProducer

Complete the earliest uncompleted call with the given error.

errorOpenIDConfiguration() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback

Return the (potentially null) error openid-configuration value as per RFC 7628: A Set of Simple Authentication and Security Layer (SASL) Mechanisms for OAuth.

errorOpt() - Method in class org.apache.kafka.clients.admin.ExclusionOpResult

errors() - Method in class org.apache.kafka.clients.admin.ListConsumerGroupsResult

Returns a future which yields just the errors which occurred.

errorScope() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback

Return the (potentially null) error scope value as per RFC 7628: A Set of Simple Authentication and Security Layer (SASL) Mechanisms for OAuth.

errorStatus() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback

Return the (potentially null) error status value as per RFC 7628: A Set of Simple Authentication and Security Layer (SASL) Mechanisms for OAuth and the IANA OAuth Extensions Error Registry.

errorUri() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback

Return the (potentially null) error URI as per RFC 6749: The OAuth 2.0 Authorization Framework.

evenClusterLoadError() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadStatusDescription

EvenClusterLoadPlan - Class in org.apache.kafka.clients.admin

Represents an SBC-computed reassignments plan to be done for the even cluster load task.

EvenClusterLoadPlan(EvenClusterLoadPlanReplicaMovementStats, EvenClusterLoadPlanBrokerRelatedStats, EvenClusterLoadPlanClusterRelatedStats, EvenClusterLoadPlanDetailedClusterBalanceStats, EvenClusterLoadPlanGoalRelatedStats) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlan

Creates a EvenClusterLoadPlan object.

EvenClusterLoadPlanBrokerRelatedStats - Class in org.apache.kafka.clients.admin

Broker-related statistics class used in the construction of EvenClusterLoadPlan.

EvenClusterLoadPlanBrokerRelatedStats(List<Integer>, List<Integer>, List<Integer>, List<Integer>) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerRelatedStats

Creates an EvenClusterLoadPlanBrokerRelatedStats object.

EvenClusterLoadPlanBrokerStats - Class in org.apache.kafka.clients.admin

Holds broker-specific information like broker ID, host, cpu usage percentage, multiple network disk usage in MB, disk usage percentage, measurements in KB/s, total leader replicas, and total replicas.

EvenClusterLoadPlanBrokerStats(int, String, double, double, double, double, double, double, double, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Creates an EvenClusterLoadPlanBrokerStats object.

EvenClusterLoadPlanClusterRelatedStats - Class in org.apache.kafka.clients.admin

Cluster-related statistics class used in the construction of EvenClusterLoadPlan.

EvenClusterLoadPlanClusterRelatedStats(int, double, List<String>, int, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanClusterRelatedStats

Creates an EvenClusterLoadPlanClusterRelatedStats object.

EvenClusterLoadPlanDetailedClusterBalanceStats - Class in org.apache.kafka.clients.admin

Cluster balance statistics class used in the construction of EvenClusterLoadPlan.

EvenClusterLoadPlanDetailedClusterBalanceStats(double, double, List<EvenClusterLoadPlanBrokerStats>, List<EvenClusterLoadPlanBrokerStats>) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanDetailedClusterBalanceStats

Creates an EvenClusterLoadPlanDetailedClusterBalanceStats object.

EvenClusterLoadPlanGoalRelatedStats - Class in org.apache.kafka.clients.admin

Goals-related statistics class used in the construction of EvenClusterLoadPlan.

EvenClusterLoadPlanGoalRelatedStats(List<String>, List<EvenClusterLoadPlanGoalStats>, List<String>, List<String>) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalRelatedStats

Creates an EvenClusterLoadPlanGoalRelatedStats object.

EvenClusterLoadPlanGoalStats - Class in org.apache.kafka.clients.admin

Holds SBC goal-specific information about the current average, maximum, and minimum resource cluster utilization statistics.

EvenClusterLoadPlanGoalStats(String, EvenClusterLoadPlanGoalStatsResources, EvenClusterLoadPlanGoalStatsResources, EvenClusterLoadPlanGoalStatsResources, EvenClusterLoadPlanGoalStatsResources, EvenClusterLoadPlanGoalStatsOverview) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStats

Creates an EvenClusterLoadPlanGoalStats object.

EvenClusterLoadPlanGoalStatsOverview - Class in org.apache.kafka.clients.admin

An overview of an SBC goal after going through an even cluster load plan computation.

EvenClusterLoadPlanGoalStatsOverview(String, List<EvenClusterLoadPlanGoalStatsOverviewRejectingGoal>, int, int, double, int, double, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsOverview

Creates an EvenClusterLoadPlanGoalStatsOverview object.

EvenClusterLoadPlanGoalStatsOverviewRejectingGoal - Class in org.apache.kafka.clients.admin

Holds SBC goal-specific information.

EvenClusterLoadPlanGoalStatsOverviewRejectingGoal(String, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsOverviewRejectingGoal

Creates an EvenClusterLoadPlanGoalStatsOverviewRejectingGoal object.

EvenClusterLoadPlanGoalStatsResources - Class in org.apache.kafka.clients.admin

Holds resource utilization statistics for both the whole cluster like information about CPU, inbound and outbound network traffic, disk usage, etc.

EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, int, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources

Creates an EvenClusterLoadPlanGoalStatsResources object.

EvenClusterLoadPlanReplicaMovementStats - Class in org.apache.kafka.clients.admin

Replica movement statistics class used in the construction of EvenClusterLoadPlan.

EvenClusterLoadPlanReplicaMovementStats(int, double, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats

Creates an EvenClusterLoadPlanReplicaMovementStats object.

EvenClusterLoadStatus - Enum in org.apache.kafka.clients.admin

The high level status of the even cluster load operation.

EvenClusterLoadStatusDescription - Class in org.apache.kafka.clients.admin

A description of an even cluster load operation, which has been listed via ConfluentAdmin.describeEvenClusterLoadStatus() The status contains EvenClusterLoadStatusDescription.healUnevenLoadTrigger that helps identify if SBC self-healing is enabled for the cluster.

EvenClusterLoadStatusDescription(BalancerSelfHealMode, EvenClusterLoadStatus, EvenClusterLoadStatus, long, long, BalancerOperationError) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadStatusDescription

Detailed status of even cluster load task.

EvenClusterLoadStatusDescription(EvenClusterLoadStatus, EvenClusterLoadStatus, long, long, BalancerOperationError) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadStatusDescription

Detailed status of even cluster load task.

EvenClusterLoadTaskInProgressException - Exception in org.apache.kafka.common.errors

Thrown if an even cluster load request for the cluster is currently in progress.

EvenClusterLoadTaskInProgressException(String) - Constructor for exception org.apache.kafka.common.errors.EvenClusterLoadTaskInProgressException

eventCount - Variable in class org.apache.kafka.common.metrics.stats.SampledStat.Sample

eventEmitter() - Method in class org.apache.kafka.common.metrics.Metrics

eventWindow() - Method in class org.apache.kafka.common.metrics.MetricConfig

eventWindow(long) - Method in class org.apache.kafka.common.metrics.MetricConfig

exception() - Method in class org.apache.kafka.clients.admin.BalancerOperationError

exception() - Method in class org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult

Return an exception if the ACL delete was not successful or null if it was.

exception() - Method in class org.apache.kafka.clients.admin.ExclusionOperationError

exception() - Method in class org.apache.kafka.server.authorizer.AclCreateResult

Returns any exception during create.

exception() - Method in class org.apache.kafka.server.authorizer.AclDeleteResult.AclBindingDeleteResult

Returns any exception that resulted in failure to delete ACL binding.

exception() - Method in class org.apache.kafka.server.authorizer.AclDeleteResult

Returns any exception while attempting to match ACL filter to delete ACLs.

EXCLUDE_CONFIG - Static variable in class org.apache.kafka.common.metrics.JmxReporter

EXCLUDE_CONFIG_ALIAS - Static variable in class org.apache.kafka.common.metrics.JmxReporter

EXCLUDE_INTERNAL_TOPICS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

exclude.internal.topics

excludedTopics() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanClusterRelatedStats

Topics excluded for replica movements.

ExclusionOp - Class in org.apache.kafka.clients.admin

A class representing an alter broker exclusion entry containing operation type and reason for exclusion.

ExclusionOp(ExclusionOp.OpType) - Constructor for class org.apache.kafka.clients.admin.ExclusionOp

ExclusionOp(ExclusionOp.OpType, String) - Constructor for class org.apache.kafka.clients.admin.ExclusionOp

ExclusionOp.OpType - Enum in org.apache.kafka.clients.admin

ExclusionOperationError - Class in org.apache.kafka.clients.admin

The error that caused an exclusion operation to fail.

ExclusionOperationError(Errors, String) - Constructor for class org.apache.kafka.clients.admin.ExclusionOperationError

ExclusionOpResult - Class in org.apache.kafka.clients.admin

ExclusionOpResult(ExclusionOp) - Constructor for class org.apache.kafka.clients.admin.ExclusionOpResult

ExclusionOpResult(ExclusionOp, ExclusionOperationError) - Constructor for class org.apache.kafka.clients.admin.ExclusionOpResult

exclusionResultByBroker() - Method in class org.apache.kafka.clients.admin.AlterBrokerReplicaExclusionsResult.ExclusionsResult

ExclusionsResult(Map<Integer, ExclusionOpResult>, boolean) - Constructor for class org.apache.kafka.clients.admin.AlterBrokerReplicaExclusionsResult.ExclusionsResult

execute(Retryable<R>) - Method in class org.apache.kafka.common.security.oauthbearer.secured.Retry

EXPIRATION_CLAIM_NAME - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.LoginAccessTokenValidator

expireDelegationToken(byte[]) - Method in interface org.apache.kafka.clients.admin.Admin

Expire a Delegation Token.

expireDelegationToken(byte[], ExpireDelegationTokenOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Expire a Delegation Token.

expireDelegationToken(byte[], ExpireDelegationTokenOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ExpireDelegationTokenOptions - Class in org.apache.kafka.clients.admin

Options for Admin.expireDelegationToken(byte[], ExpireDelegationTokenOptions).

ExpireDelegationTokenOptions() - Constructor for class org.apache.kafka.clients.admin.ExpireDelegationTokenOptions

ExpireDelegationTokenResult - Class in org.apache.kafka.clients.admin

The result of the KafkaAdminClient.expireDelegationToken(byte[], ExpireDelegationTokenOptions) call.

expiryTimePeriodMs(long) - Method in class org.apache.kafka.clients.admin.ExpireDelegationTokenOptions

expiryTimePeriodMs() - Method in class org.apache.kafka.clients.admin.ExpireDelegationTokenOptions

expiryTimestamp() - Method in class org.apache.kafka.clients.admin.ExpireDelegationTokenResult

Returns a future which yields expiry timestamp

expiryTimestamp() - Method in class org.apache.kafka.clients.admin.RenewDelegationTokenResult

Returns a future which yields expiry timestamp

expiryTimestamp() - Method in class org.apache.kafka.common.security.token.delegation.TokenInformation

ExponentialWeightedAvg - Class in org.apache.kafka.common.metrics.stats

A SampledStat that maintains an exponentially weighted average over its samples.

ExponentialWeightedAvg(double) - Constructor for class org.apache.kafka.common.metrics.stats.ExponentialWeightedAvg

extensions() - Method in class org.apache.kafka.common.security.auth.SaslExtensionsCallback

Returns always non-null SaslExtensions consisting of the extension names and values that are sent by the client to the server in the initial client SASL authentication message.

extensions(SaslExtensions) - Method in class org.apache.kafka.common.security.auth.SaslExtensionsCallback

Sets the SASL extensions on this callback.

extensions() - Method in class org.apache.kafka.common.security.scram.ScramExtensionsCallback

Returns map of the extension names and values that are sent by the client to the server in the initial client SCRAM authentication message.

extensions(Map<String, String>) - Method in class org.apache.kafka.common.security.scram.ScramExtensionsCallback

Sets the SCRAM extensions on this callback.

F

FATAL_LOG_LEVEL - Static variable in class org.apache.kafka.common.config.LogLevelConfig

The FATAL level designates a very severe error that will lead the Kafka broker to abort.

featureMetadata() - Method in class org.apache.kafka.clients.admin.DescribeFeaturesResult

FeatureMetadata - Class in org.apache.kafka.clients.admin

Encapsulates details about finalized as well as supported features.

FeatureUpdate - Class in org.apache.kafka.clients.admin

Encapsulates details about an update to a finalized feature.

FeatureUpdate(short, boolean) - Constructor for class org.apache.kafka.clients.admin.FeatureUpdate

Deprecated.

FeatureUpdate(short, FeatureUpdate.UpgradeType) - Constructor for class org.apache.kafka.clients.admin.FeatureUpdate

FeatureUpdate.UpgradeType - Enum in org.apache.kafka.clients.admin

FeatureUpdateFailedException - Exception in org.apache.kafka.common.errors

FeatureUpdateFailedException(String) - Constructor for exception org.apache.kafka.common.errors.FeatureUpdateFailedException

FeatureUpdateFailedException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.FeatureUpdateFailedException

FencedInstanceIdException - Exception in org.apache.kafka.common.errors

FencedInstanceIdException(String) - Constructor for exception org.apache.kafka.common.errors.FencedInstanceIdException

FencedInstanceIdException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.FencedInstanceIdException

FencedLeaderEpochException - Exception in org.apache.kafka.common.errors

The request contained a leader epoch which is smaller than that on the broker that received the request.

FencedLeaderEpochException(String) - Constructor for exception org.apache.kafka.common.errors.FencedLeaderEpochException

FencedLeaderEpochException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.FencedLeaderEpochException

fencedProducers() - Method in class org.apache.kafka.clients.admin.FenceProducersResult

Return a map from transactional ID to futures which can be used to check the status of individual fencings.

fenceProducer() - Method in class org.apache.kafka.clients.producer.MockProducer

fenceProducers(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin

Fence out all active producers that use any of the provided transactional IDs, with the default options.

fenceProducers(Collection<String>, FenceProducersOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Fence out all active producers that use any of the provided transactional IDs.

fenceProducers(Collection<String>, FenceProducersOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

FenceProducersOptions - Class in org.apache.kafka.clients.admin

Options for Admin.fenceProducers(Collection, FenceProducersOptions) The API of this class is evolving.

FenceProducersOptions() - Constructor for class org.apache.kafka.clients.admin.FenceProducersOptions

FenceProducersResult - Class in org.apache.kafka.clients.admin

The result of the Admin.fenceProducers(Collection) call.

FETCH_MAX_BYTES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

fetch.max.bytes

FETCH_MAX_WAIT_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

fetch.max.wait.ms

FETCH_MIN_BYTES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

fetch.min.bytes

FetchSessionIdNotFoundException - Exception in org.apache.kafka.common.errors

FetchSessionIdNotFoundException() - Constructor for exception org.apache.kafka.common.errors.FetchSessionIdNotFoundException

FetchSessionIdNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.FetchSessionIdNotFoundException

FetchSessionTopicIdException - Exception in org.apache.kafka.common.errors

FetchSessionTopicIdException(String) - Constructor for exception org.apache.kafka.common.errors.FetchSessionTopicIdException

FILE_DELETE_DELAY_MS_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

FILE_DELETE_DELAY_MS_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

FileConfigProvider - Class in org.apache.kafka.common.config.provider

An implementation of ConfigProvider that represents a Properties file.

FileConfigProvider() - Constructor for class org.apache.kafka.common.config.provider.FileConfigProvider

FileTokenRetriever - Class in org.apache.kafka.common.security.oauthbearer.secured

FileTokenRetriever is an AccessTokenRetriever that will load the contents, interpreting them as a JWT access key in the serialized form.

FileTokenRetriever(Path) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.FileTokenRetriever

fillInStackTrace() - Method in exception org.apache.kafka.common.errors.ApiException

fillInStackTrace() - Method in exception org.apache.kafka.common.metrics.QuotaViolationException

filteredProducerIds() - Method in class org.apache.kafka.clients.admin.ListTransactionsOptions

Returns the set of producerIds that are being filtered or empty if none have been specified.

filteredStates() - Method in class org.apache.kafka.clients.admin.ListTransactionsOptions

Returns the set of states to be filtered or empty if no states have been specified.

filterProducerIds(Collection<Long>) - Method in class org.apache.kafka.clients.admin.ListTransactionsOptions

Filter only the transactions from producers in a specific set of producerIds.

filterStates(Collection<TransactionState>) - Method in class org.apache.kafka.clients.admin.ListTransactionsOptions

Filter only the transactions that are in a specific set of states.

finalizedFeatures() - Method in class org.apache.kafka.clients.admin.FeatureMetadata

Returns a map of finalized feature versions.

finalizedFeaturesEpoch() - Method in class org.apache.kafka.clients.admin.FeatureMetadata

The epoch for the finalized features.

FinalizedVersionRange - Class in org.apache.kafka.clients.admin

Represents a range of version levels supported by every broker in a cluster for some feature.

findIndefiniteField() - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

Returns a string describing an ANY or UNKNOWN field, or null if there is no such field.

findIndefiniteField() - Method in class org.apache.kafka.common.acl.AclBindingFilter

Return a string describing an ANY or UNKNOWN field, or null if there is no such field.

findIndefiniteField() - Method in class org.apache.kafka.common.resource.ResourcePatternFilter

Float() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable Float type.

FloatDeserializer - Class in org.apache.kafka.common.serialization

FloatDeserializer() - Constructor for class org.apache.kafka.common.serialization.FloatDeserializer

FloatSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.FloatSerde

FloatSerializer - Class in org.apache.kafka.common.serialization

FloatSerializer() - Constructor for class org.apache.kafka.common.serialization.FloatSerializer

flush() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Invoking this method makes all buffered records immediately available to send (even if linger.ms is greater than 0) and blocks on the completion of the requests associated with these records.

flush() - Method in class org.apache.kafka.clients.producer.MockProducer

flush() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.flush()

FLUSH_MESSAGES_INTERVAL_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

FLUSH_MESSAGES_INTERVAL_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

FLUSH_MS_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

FLUSH_MS_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

flushed() - Method in class org.apache.kafka.clients.producer.MockProducer

flushException - Variable in class org.apache.kafka.clients.producer.MockProducer

followerNetworkInKBps() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Inbound traffic from replicas that it follows.

forBooleanValues(MetricName, MetricName) - Static method in class org.apache.kafka.common.metrics.stats.Frequencies

Create a Frequencies instance with metrics for the frequency of a boolean sensor that records 0.0 for false and 1.0 for true.

force() - Method in class org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec

Whether the operation will be forced if the cluster has already reached the max number of brokers that can be demoted.

force() - Method in class org.apache.kafka.clients.admin.DeleteClusterLinksOptions

Whether to force deletion of the cluster link even if it's in use.

force(boolean) - Method in class org.apache.kafka.clients.admin.DeleteClusterLinksOptions

Sets whether to force deletion of the cluster link even if it's in use.

forConfig(String) - Static method in enum org.apache.kafka.common.config.SslClientAuth

forGroupId(String) - Static method in exception org.apache.kafka.common.errors.GroupAuthorizationException

forId(byte) - Static method in enum org.apache.kafka.clients.admin.AlterConfigOp.OpType

forId(byte) - Static method in enum org.apache.kafka.clients.admin.AlterMirrorOp

forId(byte) - Static method in enum org.apache.kafka.clients.admin.ExclusionOp.OpType

forId(byte) - Static method in enum org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.RebalanceProtocol

forId(byte) - Static method in enum org.apache.kafka.common.config.ConfigResource.Type

forId(byte) - Static method in enum org.apache.kafka.common.IsolationLevel

forId(int) - Static method in enum org.apache.kafka.common.metrics.Sensor.RecordingLevel

forId(short) - Static method in enum org.apache.kafka.common.security.auth.SecurityProtocol

forName(String) - Static method in enum org.apache.kafka.common.metrics.Sensor.RecordingLevel

Case insensitive lookup by protocol name

forName(String) - Static method in enum org.apache.kafka.common.security.auth.SecurityProtocol

Case insensitive lookup by protocol name

forSuperClass(Class<?>) - Static method in class org.apache.kafka.common.config.ConfigDef.ConcreteSubClassValidator

forTimestamp(long) - Static method in class org.apache.kafka.clients.admin.OffsetSpec

Used to retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition

Frequencies - Class in org.apache.kafka.common.metrics.stats

A CompoundStat that represents a normalized distribution with a Frequency metric for each bucketed value.

Frequencies(int, double, double, Frequency...) - Constructor for class org.apache.kafka.common.metrics.stats.Frequencies

Create a Frequencies that captures the values in the specified range into the given number of buckets, where the buckets are centered around the minimum, maximum, and intermediate values.

frequency(MetricConfig, long, double) - Method in class org.apache.kafka.common.metrics.stats.Frequencies

Return the computed frequency describing the number of occurrences of the values in the bucket for the given center point, relative to the total number of occurrences in the samples.

Frequency - Class in org.apache.kafka.common.metrics.stats

Definition of a frequency metric used in a Frequencies compound statistic.

Frequency(MetricName, double) - Constructor for class org.apache.kafka.common.metrics.stats.Frequency

Create an instance with the given name and center point value.

fromBin(int) - Method in interface org.apache.kafka.common.metrics.stats.Histogram.BinScheme

Determine the value at the upper range of the specified bin.

fromBin(int) - Method in class org.apache.kafka.common.metrics.stats.Histogram.ConstantBinScheme

fromBin(int) - Method in class org.apache.kafka.common.metrics.stats.Histogram.LinearBinScheme

fromCode(int) - Static method in enum org.apache.kafka.clients.admin.FeatureUpdate.UpgradeType

fromCode(byte) - Static method in enum org.apache.kafka.common.acl.AclOperation

Return the AclOperation with the provided code or `AclOperation.UNKNOWN` if one cannot be found.

fromCode(byte) - Static method in enum org.apache.kafka.common.acl.AclPermissionType

Return the AclPermissionType with the provided code or `AclPermissionType.UNKNOWN` if one cannot be found.

fromCode(byte) - Static method in enum org.apache.kafka.common.resource.PatternType

Return the PatternType with the provided code or PatternType.UNKNOWN if one cannot be found.

fromCode(byte) - Static method in enum org.apache.kafka.common.resource.ResourceType

Return the ResourceType with the provided code or `ResourceType.UNKNOWN` if one cannot be found.

fromMechanismName(String) - Static method in enum org.apache.kafka.clients.admin.ScramMechanism

fromShort(short) - Static method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.ConnectionMode

fromShort(short) - Static method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.LinkMode

fromShort(short) - Static method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState

fromString(String) - Static method in enum org.apache.kafka.common.acl.AclOperation

Parse the given string as an ACL operation.

fromString(String) - Static method in enum org.apache.kafka.common.acl.AclPermissionType

Parse the given string as an ACL permission.

fromString(String) - Static method in enum org.apache.kafka.common.resource.PatternType

Return the PatternType with the provided name or PatternType.UNKNOWN if one cannot be found.

fromString(String) - Static method in enum org.apache.kafka.common.resource.ResourceType

Parse the given string as an ACL resource type.

fromString(String) - Static method in class org.apache.kafka.common.Uuid

Creates a UUID based on a base64 string encoding used in the toString() method.

fromType(byte) - Static method in enum org.apache.kafka.clients.admin.ScramMechanism

Function() - Constructor for class org.apache.kafka.common.KafkaFuture.Function

Deprecated.

future() - Method in class org.apache.kafka.clients.admin.DescribeLeadershipPriorityResult

Returns a future collection of demoted brokers and their reasons for demotion.

G

Gauge<T> - Interface in org.apache.kafka.common.metrics

A gauge metric is an instantaneous reading of a particular value.

generalOperationStatus() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

The current high-level status of the broker addition operation

generalOperationStatus() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

Nullable, the current high-level status of the broker removal operation.

generationId() - Method in class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

get(String) - Method in class org.apache.kafka.clients.admin.Config

Get the configuration entry with the provided name or null if there isn't one.

get(String) - Method in class org.apache.kafka.common.config.AbstractConfig

get(String) - Method in interface org.apache.kafka.common.config.provider.ConfigProvider

Retrieves the data at the given path.

get(String, Set<String>) - Method in interface org.apache.kafka.common.config.provider.ConfigProvider

Retrieves the data with the given keys at the given path.

get(String) - Method in class org.apache.kafka.common.config.provider.DirectoryConfigProvider

Retrieves the data contained in regular files in the directory given by path.

get(String, Set<String>) - Method in class org.apache.kafka.common.config.provider.DirectoryConfigProvider

Retrieves the data contained in the regular files named by keys in the directory given by path.

get(String) - Method in class org.apache.kafka.common.config.provider.FileConfigProvider

Retrieves the data at the given Properties file.

get(String, Set<String>) - Method in class org.apache.kafka.common.config.provider.FileConfigProvider

Retrieves the data with the given keys at the given Properties file.

get() - Method in class org.apache.kafka.common.KafkaFuture

Waits if necessary for this future to complete, and then returns its result.

get(long, TimeUnit) - Method in class org.apache.kafka.common.KafkaFuture

Waits if necessary for at most the given time for this future to complete, and then returns its result, if available.

get(String) - Method in class org.apache.kafka.common.security.oauthbearer.secured.ConfigurationUtils

get() - Method in interface org.apache.kafka.common.security.oauthbearer.secured.ValidatorAccessTokenValidator.ClaimSupplier

getAssignorInstances(List<String>, Map<String, Object>) - Static method in interface org.apache.kafka.clients.consumer.ConsumerPartitionAssignor

Get a list of configured instances of ConsumerPartitionAssignor based on the class names/types specified by ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG

getBoolean(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getClass(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getConfiguredInstance(String, Class<T>) - Method in class org.apache.kafka.common.config.AbstractConfig

Get a configured instance of the give class specified by the given configuration key.

getConfiguredInstance(String, Class<T>, Map<String, Object>) - Method in class org.apache.kafka.common.config.AbstractConfig

Get a configured instance of the give class specified by the given configuration key.

getConfiguredInstances(String, Class<T>) - Method in class org.apache.kafka.common.config.AbstractConfig

Get a list of configured instances of the given class specified by the given configuration key.

getConfiguredInstances(String, Class<T>, Map<String, Object>) - Method in class org.apache.kafka.common.config.AbstractConfig

Get a list of configured instances of the given class specified by the given configuration key.

getConfiguredInstances(List<String>, Class<T>, Map<String, Object>) - Method in class org.apache.kafka.common.config.AbstractConfig

Get a list of configured instances of the given class specified by the given configuration key.

getConfigValue(ConfigDef.ConfigKey, String) - Method in class org.apache.kafka.common.config.ConfigDef

getCurrentReplicaLogDir() - Method in class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo

getCurrentReplicaOffsetLag() - Method in class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo

getDouble(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getFutureReplicaLogDir() - Method in class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo

getFutureReplicaOffsetLag() - Method in class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo

getHeader() - Method in class org.apache.kafka.common.security.oauthbearer.secured.SerializedJwt

Returns the first section--the JWT header--in its base 64-encoded form.

getInnerSerializer() - Method in class org.apache.kafka.common.serialization.ListSerializer

getInt(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getJsonWebKeys() - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwks

Our implementation avoids the blocking call within HttpsJwks.refresh() that is sometimes called internal to HttpsJwks.getJsonWebKeys().

getLeastSignificantBits() - Method in class org.apache.kafka.common.Uuid

Returns the least significant bits of the UUID's 128 value.

getList(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getLocation() - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwks

getLong(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getMostSignificantBits() - Method in class org.apache.kafka.common.Uuid

Returns the most significant bits of the UUID's 128 value.

getName() - Method in class org.apache.kafka.common.security.auth.KafkaPrincipal

getNow(T) - Method in class org.apache.kafka.common.KafkaFuture

Returns the result value (or throws any encountered exception) if completed, else returns the given valueIfAbsent.

getOptions(String, List<AppConfigurationEntry>) - Static method in class org.apache.kafka.common.security.oauthbearer.secured.JaasOptionsUtils

getPassword(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getPayload() - Method in class org.apache.kafka.common.security.oauthbearer.secured.SerializedJwt

Returns the second section--the JWT payload--in its base 64-encoded form.

getPrincipalType() - Method in class org.apache.kafka.common.security.auth.KafkaPrincipal

getPrintableForm() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

getProvider() - Method in interface org.apache.kafka.common.security.auth.SecurityProviderCreator

Generate the security provider configured

getQuotaViolations(long, boolean) - Method in class org.apache.kafka.common.metrics.Sensor

getSensor(String) - Method in class org.apache.kafka.common.metrics.Metrics

Get the sensor with the given name if it exists

getShort(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getSignature() - Method in class org.apache.kafka.common.security.oauthbearer.secured.SerializedJwt

Returns the third section--the JWT signature--in its base 64-encoded form.

getSslClientConfig() - Method in class org.apache.kafka.common.security.oauthbearer.secured.JaasOptionsUtils

getString(String) - Method in class org.apache.kafka.common.config.AbstractConfig

getToken() - Method in class org.apache.kafka.common.security.oauthbearer.secured.SerializedJwt

Returns the entire base 64-encoded JWT.

getValue() - Method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.ConnectionMode

getValue() - Method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.LinkMode

getValue() - Method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState

goalName() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStats

The name of the goal.

goalName() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsOverviewRejectingGoal

Name of the rejecting goal.

goalOverview() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStats

Post SBC goal optimization statistics for the goal.

goalRelatedStats() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlan

Goal-related statistics.

goalStats() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalRelatedStats

Goal statistics for all goals.

goalStatus() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsOverview

Status of the goal after cluster rebalance.

group - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

group() - Method in class org.apache.kafka.common.MetricName

group() - Method in class org.apache.kafka.common.MetricNameTemplate

Get the name of the group.

GROUP_ID_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

group.id

GROUP_INSTANCE_ID_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

group.instance.id

GroupAssignment(Map<String, ConsumerPartitionAssignor.Assignment>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupAssignment

groupAssignment() - Method in class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupAssignment

GroupAuthorizationException - Exception in org.apache.kafka.common.errors

GroupAuthorizationException(String, String) - Constructor for exception org.apache.kafka.common.errors.GroupAuthorizationException

GroupAuthorizationException(String) - Constructor for exception org.apache.kafka.common.errors.GroupAuthorizationException

groupId() - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

The id of the consumer group.

groupId() - Method in class org.apache.kafka.clients.admin.ConsumerGroupListing

Consumer Group Id

groupId() - Method in class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

groupId() - Method in exception org.apache.kafka.common.errors.GroupAuthorizationException

Return the group ID that failed authorization.

GroupIdNotFoundException - Exception in org.apache.kafka.common.errors

GroupIdNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.GroupIdNotFoundException

groupInstanceId() - Method in class org.apache.kafka.clients.admin.MemberDescription

The instance id of the group member.

groupInstanceId() - Method in class org.apache.kafka.clients.admin.MemberToRemove

groupInstanceId() - Method in class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

groupInstanceId() - Method in class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Subscription

GroupMaxSizeReachedException - Exception in org.apache.kafka.common.errors

Indicates that a consumer group is already at its configured maximum capacity and cannot accommodate more members

GroupMaxSizeReachedException(String) - Constructor for exception org.apache.kafka.common.errors.GroupMaxSizeReachedException

groupMetadata() - Method in interface org.apache.kafka.clients.consumer.Consumer

groupMetadata() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Return the current group metadata associated with this consumer.

groupMetadata() - Method in class org.apache.kafka.clients.consumer.MockConsumer

GroupNotEmptyException - Exception in org.apache.kafka.common.errors

GroupNotEmptyException(String) - Constructor for exception org.apache.kafka.common.errors.GroupNotEmptyException

groups() - Method in class org.apache.kafka.common.config.ConfigDef

Get the groups for the configuration

GroupSubscribedToTopicException - Exception in org.apache.kafka.common.errors

GroupSubscribedToTopicException(String) - Constructor for exception org.apache.kafka.common.errors.GroupSubscribedToTopicException

GroupSubscription(Map<String, ConsumerPartitionAssignor.Subscription>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupSubscription

groupSubscription() - Method in class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupSubscription

GSSAPI_MECHANISM - Static variable in class org.apache.kafka.common.config.SaslConfigs

H

handle(Callback[]) - Method in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler

handle(Callback[]) - Method in class org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler

hasDefault() - Method in class org.apache.kafka.common.config.ConfigDef.ConfigKey

hasExpired() - Method in class org.apache.kafka.common.metrics.Sensor

Return true if the Sensor is eligible for removal due to inactivity.

hash - Variable in class org.apache.kafka.common.Node

hashCode() - Method in class org.apache.kafka.clients.admin.AbortTransactionSpec

hashCode() - Method in class org.apache.kafka.clients.admin.AlterConfigOp

hashCode() - Method in class org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec

hashCode() - Method in class org.apache.kafka.clients.admin.BalancerOperationError

hashCode() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

hashCode() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

hashCode() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

hashCode() - Method in class org.apache.kafka.clients.admin.Config

hashCode() - Method in class org.apache.kafka.clients.admin.ConfigEntry.ConfigSynonym

hashCode() - Method in class org.apache.kafka.clients.admin.ConfigEntry

hashCode() - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

hashCode() - Method in class org.apache.kafka.clients.admin.ConsumerGroupListing

hashCode() - Method in class org.apache.kafka.clients.admin.DescribeProducersOptions

hashCode() - Method in class org.apache.kafka.clients.admin.ExclusionOp

hashCode() - Method in class org.apache.kafka.clients.admin.FeatureMetadata

hashCode() - Method in class org.apache.kafka.clients.admin.FeatureUpdate

hashCode() - Method in class org.apache.kafka.clients.admin.FinalizedVersionRange

hashCode() - Method in class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsSpec

hashCode() - Method in class org.apache.kafka.clients.admin.ListTopicsOptions

hashCode() - Method in class org.apache.kafka.clients.admin.ListTransactionsOptions

hashCode() - Method in class org.apache.kafka.clients.admin.MemberAssignment

hashCode() - Method in class org.apache.kafka.clients.admin.MemberDescription

hashCode() - Method in class org.apache.kafka.clients.admin.MemberToRemove

hashCode() - Method in class org.apache.kafka.clients.admin.MirrorTopicDescription

hashCode() - Method in class org.apache.kafka.clients.admin.NewClusterLink

hashCode() - Method in class org.apache.kafka.clients.admin.NewMirrorTopic

hashCode() - Method in class org.apache.kafka.clients.admin.NewTopic

hashCode() - Method in class org.apache.kafka.clients.admin.ProducerState

hashCode() - Method in class org.apache.kafka.clients.admin.QuorumInfo

hashCode() - Method in class org.apache.kafka.clients.admin.QuorumInfo.ReplicaState

hashCode() - Method in class org.apache.kafka.clients.admin.RecordsToDelete

hashCode() - Method in class org.apache.kafka.clients.admin.ScramCredentialInfo

hashCode() - Method in class org.apache.kafka.clients.admin.SupportedVersionRange

hashCode() - Method in class org.apache.kafka.clients.admin.TopicDescription

hashCode() - Method in class org.apache.kafka.clients.admin.TransactionDescription

hashCode() - Method in class org.apache.kafka.clients.admin.TransactionListing

hashCode() - Method in class org.apache.kafka.clients.admin.UserScramCredentialsDescription

hashCode() - Method in class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

hashCode() - Method in class org.apache.kafka.clients.consumer.OffsetAndMetadata

hashCode() - Method in class org.apache.kafka.clients.consumer.OffsetAndTimestamp

hashCode() - Method in class org.apache.kafka.clients.producer.ProducerRecord

hashCode() - Method in class org.apache.kafka.common.acl.AccessControlEntry

hashCode() - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

hashCode() - Method in class org.apache.kafka.common.acl.AclBinding

hashCode() - Method in class org.apache.kafka.common.acl.AclBindingFilter

hashCode() - Method in class org.apache.kafka.common.Cluster

hashCode() - Method in class org.apache.kafka.common.ClusterResource

hashCode() - Method in class org.apache.kafka.common.config.AbstractConfig

hashCode() - Method in class org.apache.kafka.common.config.ConfigResource

hashCode() - Method in class org.apache.kafka.common.config.ConfigValue

hashCode() - Method in class org.apache.kafka.common.Endpoint

hashCode() - Method in class org.apache.kafka.common.MetricName

hashCode() - Method in class org.apache.kafka.common.MetricNameTemplate

hashCode() - Method in class org.apache.kafka.common.metrics.Quota

hashCode() - Method in class org.apache.kafka.common.Node

hashCode() - Method in class org.apache.kafka.common.quota.ClientQuotaAlteration.Op

hashCode() - Method in class org.apache.kafka.common.quota.ClientQuotaEntity

hashCode() - Method in class org.apache.kafka.common.quota.ClientQuotaFilter

hashCode() - Method in class org.apache.kafka.common.quota.ClientQuotaFilterComponent

hashCode() - Method in class org.apache.kafka.common.resource.Resource

hashCode() - Method in class org.apache.kafka.common.resource.ResourcePattern

hashCode() - Method in class org.apache.kafka.common.resource.ResourcePatternFilter

hashCode() - Method in class org.apache.kafka.common.security.auth.KafkaPrincipal

hashCode() - Method in class org.apache.kafka.common.security.auth.SaslExtensions

Implements hashCode using the native implementation from Object.hashCode().

hashCode() - Method in class org.apache.kafka.common.security.token.delegation.DelegationToken

hashCode() - Method in class org.apache.kafka.common.security.token.delegation.TokenInformation

hashCode() - Method in class org.apache.kafka.common.TopicIdPartition

hashCode() - Method in class org.apache.kafka.common.TopicPartition

hashCode() - Method in class org.apache.kafka.common.TopicPartitionInfo

hashCode() - Method in class org.apache.kafka.common.TopicPartitionReplica

hashCode() - Method in class org.apache.kafka.common.Uuid

Returns a hash code for this UUID

hashCode() - Method in class org.apache.kafka.server.authorizer.Action

hashCode() - Method in class org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata

hashCode() - Method in class org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata

hasMetrics() - Method in class org.apache.kafka.common.metrics.Sensor

Return if metrics were registered with this sensor.

hasOffset() - Method in class org.apache.kafka.clients.producer.RecordMetadata

Indicates whether the record metadata includes the offset.

hasRack() - Method in class org.apache.kafka.common.Node

True if this node has a defined rack

hasTimestamp() - Method in class org.apache.kafka.clients.producer.RecordMetadata

Indicates whether the record metadata includes the timestamp.

Header - Interface in org.apache.kafka.common.header

headers() - Method in class org.apache.kafka.clients.consumer.ConsumerRecord

The headers (never null)

headers() - Method in class org.apache.kafka.clients.producer.ProducerRecord

headers() - Method in class org.apache.kafka.common.config.ConfigDef

Headers - Interface in org.apache.kafka.common.header

headers(String) - Method in interface org.apache.kafka.common.header.Headers

Returns all headers for the given key, in the order they were added in, if present.

healUnevenLoadTrigger() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadStatusDescription

HEARTBEAT_INTERVAL_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

heartbeat.interval.ms

highWatermark() - Method in class org.apache.kafka.clients.admin.QuorumInfo

Histogram - Class in org.apache.kafka.common.metrics.stats

Histogram(Histogram.BinScheme) - Constructor for class org.apache.kafka.common.metrics.stats.Histogram

Histogram.BinScheme - Interface in org.apache.kafka.common.metrics.stats

An algorithm for determining the bin in which a value is to be placed as well as calculating the upper end of each bin.

Histogram.ConstantBinScheme - Class in org.apache.kafka.common.metrics.stats

A scheme for calculating the bins where the width of each bin is a constant determined by the range of values and the number of bins.

Histogram.LinearBinScheme - Class in org.apache.kafka.common.metrics.stats

A scheme for calculating the bins where the width of each bin is one more than the previous bin, and therefore the bin widths are increasing at a linear rate.

history() - Method in class org.apache.kafka.clients.producer.MockProducer

Get the list of sent records since the last call to MockProducer.clear()

hmac() - Method in class org.apache.kafka.common.security.token.delegation.DelegationToken

hmacAsBase64String() - Method in class org.apache.kafka.common.security.token.delegation.DelegationToken

host() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Broker's host.

host() - Method in class org.apache.kafka.clients.admin.MemberDescription

The host where the group member is running.

host() - Method in class org.apache.kafka.common.acl.AccessControlEntry

Return the host or `*` for all hosts.

host() - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

Return the host or null.

host() - Method in class org.apache.kafka.common.Endpoint

Returns advertised host name of this endpoint.

host - Variable in class org.apache.kafka.common.Node

host() - Method in class org.apache.kafka.common.Node

The host name for this node

HOST_RESOLVER_CLASS_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

HttpAccessTokenRetriever - Class in org.apache.kafka.common.security.oauthbearer.secured

HttpAccessTokenRetriever is an AccessTokenRetriever that will communicate with an OAuth/OIDC provider directly via HTTP to post client credentials (OAuthBearerLoginCallbackHandler.CLIENT_ID_CONFIG/OAuthBearerLoginCallbackHandler.CLIENT_SECRET_CONFIG) to a publicized token endpoint URL (SaslConfigs.SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL).

HttpAccessTokenRetriever(String, String, String, SSLSocketFactory, String, long, long, Integer, Integer) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.HttpAccessTokenRetriever

I

id() - Method in enum org.apache.kafka.clients.admin.AlterConfigOp.OpType

id() - Method in enum org.apache.kafka.clients.admin.AlterLeadershipPrioritySpec.PriorityOperationEnum

id() - Method in enum org.apache.kafka.clients.admin.AlterMirrorOp

id() - Method in enum org.apache.kafka.clients.admin.BrokerLeadershipPriorityResult.LeadershipPriorityEnum

id() - Method in enum org.apache.kafka.clients.admin.ExclusionOp.OpType

id() - Method in enum org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.RebalanceProtocol

id() - Method in enum org.apache.kafka.common.config.ConfigResource.Type

id() - Method in enum org.apache.kafka.common.IsolationLevel

id - Variable in enum org.apache.kafka.common.metrics.Sensor.RecordingLevel

the permanent and immutable id of an API--this can't change ever

id - Variable in class org.apache.kafka.common.Node

id() - Method in class org.apache.kafka.common.Node

The node id of this node

id - Variable in enum org.apache.kafka.common.security.auth.SecurityProtocol

The permanent and immutable id of a security protocol -- this can't change, and must match kafka.cluster.SecurityProtocol

idString - Variable in class org.apache.kafka.common.Node

idString() - Method in class org.apache.kafka.common.Node

String representation of the node id.

ignore(String) - Method in class org.apache.kafka.common.config.AbstractConfig

ignoredExtensions() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback

IllegalGenerationException - Exception in org.apache.kafka.common.errors

IllegalGenerationException() - Constructor for exception org.apache.kafka.common.errors.IllegalGenerationException

IllegalGenerationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.IllegalGenerationException

IllegalGenerationException(String) - Constructor for exception org.apache.kafka.common.errors.IllegalGenerationException

IllegalGenerationException(Throwable) - Constructor for exception org.apache.kafka.common.errors.IllegalGenerationException

IllegalSaslStateException - Exception in org.apache.kafka.common.errors

This exception indicates unexpected requests prior to SASL authentication.

IllegalSaslStateException(String) - Constructor for exception org.apache.kafka.common.errors.IllegalSaslStateException

IllegalSaslStateException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.IllegalSaslStateException

importance - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

in(String...) - Static method in class org.apache.kafka.common.config.ConfigDef.CaseInsensitiveValidString

in(String...) - Static method in class org.apache.kafka.common.config.ConfigDef.ValidList

in(String...) - Static method in class org.apache.kafka.common.config.ConfigDef.ValidString

INCLUDE_CONFIG - Static variable in class org.apache.kafka.common.metrics.JmxReporter

INCLUDE_CONFIG_ALIAS - Static variable in class org.apache.kafka.common.metrics.JmxReporter

includeAuthorizedOperations(boolean) - Method in class org.apache.kafka.clients.admin.DescribeClusterOptions

includeAuthorizedOperations() - Method in class org.apache.kafka.clients.admin.DescribeClusterOptions

Specify if authorized operations should be included in the response.

includeAuthorizedOperations(boolean) - Method in class org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions

includeAuthorizedOperations() - Method in class org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions

includeAuthorizedOperations(boolean) - Method in class org.apache.kafka.clients.admin.DescribeTopicsOptions

includeAuthorizedOperations() - Method in class org.apache.kafka.clients.admin.DescribeTopicsOptions

includeDocumentation() - Method in class org.apache.kafka.clients.admin.DescribeConfigsOptions

Return true if config documentation should be returned in the response.

includeDocumentation(boolean) - Method in class org.apache.kafka.clients.admin.DescribeConfigsOptions

Set to true if config documentation should be returned in the response.

includeLinkedReplicas() - Method in class org.apache.kafka.clients.admin.ReplicaStatusOptions

Whether the request should also include the replica status for linked replicas.

includeLinkedReplicas(boolean) - Method in class org.apache.kafka.clients.admin.ReplicaStatusOptions

Sets whether the request should also include the replica status for linked replicas.

includeStopped() - Method in class org.apache.kafka.clients.admin.ListMirrorsOptions

Whether to include stopped mirror topics.

includeStopped(boolean) - Method in class org.apache.kafka.clients.admin.ListMirrorsOptions

Sets whether to include stopped mirror topics.

includeSynonyms() - Method in class org.apache.kafka.clients.admin.DescribeConfigsOptions

Return true if synonym configs should be returned in the response.

includeSynonyms(boolean) - Method in class org.apache.kafka.clients.admin.DescribeConfigsOptions

Set to true if synonym configs should be returned in the response.

includeTopics() - Method in class org.apache.kafka.clients.admin.DescribeClusterLinksOptions

Whether to include the topics that are linked for the cluster link.

includeTopics(boolean) - Method in class org.apache.kafka.clients.admin.DescribeClusterLinksOptions

Set whether to include the topics that are linked for the cluster link.

includeTopics() - Method in class org.apache.kafka.clients.admin.ListClusterLinksOptions

Whether to include the topics that are linked for the cluster link.

includeTopics(boolean) - Method in class org.apache.kafka.clients.admin.ListClusterLinksOptions

Set whether to include the topics that are linked for the cluster link.

InconsistentClusterIdException - Exception in org.apache.kafka.common.errors

InconsistentClusterIdException(String) - Constructor for exception org.apache.kafka.common.errors.InconsistentClusterIdException

InconsistentClusterIdException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InconsistentClusterIdException

InconsistentGroupProtocolException - Exception in org.apache.kafka.common.errors

InconsistentGroupProtocolException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InconsistentGroupProtocolException

InconsistentGroupProtocolException(String) - Constructor for exception org.apache.kafka.common.errors.InconsistentGroupProtocolException

InconsistentTopicIdException - Exception in org.apache.kafka.common.errors

InconsistentTopicIdException(String) - Constructor for exception org.apache.kafka.common.errors.InconsistentTopicIdException

InconsistentVoterSetException - Exception in org.apache.kafka.common.errors

InconsistentVoterSetException(String) - Constructor for exception org.apache.kafka.common.errors.InconsistentVoterSetException

InconsistentVoterSetException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InconsistentVoterSetException

increaseTo(int) - Static method in class org.apache.kafka.clients.admin.NewPartitions

Increase the partition count for a topic to the given totalCount.

increaseTo(int, List<List<Integer>>) - Static method in class org.apache.kafka.clients.admin.NewPartitions

Increase the partition count for a topic to the given totalCount assigning the new partitions according to the given newAssignments.

incrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>) - Method in interface org.apache.kafka.clients.admin.Admin

Incrementally updates the configuration for the specified resources with default options.

incrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

Incrementally update the configuration for the specified resources.

incrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

INDEX_INTERVAL_BYTES_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

INDEX_INTERVAL_BYTES_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

IneligibleReplicaException - Exception in org.apache.kafka.common.errors

IneligibleReplicaException(String) - Constructor for exception org.apache.kafka.common.errors.IneligibleReplicaException

INFO_LOG_LEVEL - Static variable in class org.apache.kafka.common.config.LogLevelConfig

The INFO level designates informational messages that highlight normal Kafka events at a coarse-grained level

init(List<KafkaMetric>) - Method in class org.apache.kafka.common.metrics.JmxReporter

init(List<KafkaMetric>) - Method in interface org.apache.kafka.common.metrics.MetricsReporter

This is called when the reporter is first registered to initially register all existing metrics

init() - Method in class org.apache.kafka.common.security.oauthbearer.secured.FileTokenRetriever

init() - Method in interface org.apache.kafka.common.security.oauthbearer.secured.Initable

Lifecycle method to perform any one-time initialization of the retriever.

init() - Method in class org.apache.kafka.common.security.oauthbearer.secured.JwksFileVerificationKeyResolver

init() - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwks

init() - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwksVerificationKeyResolver

Initable - Interface in org.apache.kafka.common.security.oauthbearer.secured

initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule

initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class org.apache.kafka.common.security.plain.PlainLoginModule

initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class org.apache.kafka.common.security.scram.ScramLoginModule

initialValue - Variable in class org.apache.kafka.common.metrics.stats.SampledStat.Sample

initTransactionException - Variable in class org.apache.kafka.clients.producer.MockProducer

initTransactions() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Needs to be called before any other methods when the transactional.id is set in the configuration.

initTransactions() - Method in class org.apache.kafka.clients.producer.MockProducer

initTransactions() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.initTransactions()

innerDeserializer() - Method in class org.apache.kafka.common.serialization.ListDeserializer

inputExtensions() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback

INSTANCE - Static variable in exception org.apache.kafka.common.errors.CoordinatorNotAvailableException

INSTANCE - Static variable in exception org.apache.kafka.common.errors.DisconnectException

InstantiableClassValidator() - Constructor for class org.apache.kafka.common.config.ConfigDef.InstantiableClassValidator

inStates(Set<ConsumerGroupState>) - Method in class org.apache.kafka.clients.admin.ListConsumerGroupsOptions

If states is set, only groups in these states will be returned by listConsumerGroups() Otherwise, all groups are returned.

InsufficientRebalancePlanMetricsException - Exception in org.apache.kafka.common.errors

Thrown when the cluster does not have enough metrics to compute a rebalance plan for removing a broker.

InsufficientRebalancePlanMetricsException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InsufficientRebalancePlanMetricsException

InsufficientRebalancePlanMetricsException(String) - Constructor for exception org.apache.kafka.common.errors.InsufficientRebalancePlanMetricsException

inSyncReplicas() - Method in class org.apache.kafka.common.PartitionInfo

The subset of the replicas that are in sync, that is caught-up to the leader and ready to take over as leader if the leader should fail

Integer() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable Integer type.

IntegerDeserializer - Class in org.apache.kafka.common.serialization

IntegerDeserializer() - Constructor for class org.apache.kafka.common.serialization.IntegerDeserializer

IntegerSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.IntegerSerde

IntegerSerializer - Class in org.apache.kafka.common.serialization

IntegerSerializer() - Constructor for class org.apache.kafka.common.serialization.IntegerSerializer

interBrokerEndpoint() - Method in interface org.apache.kafka.server.authorizer.AuthorizerServerInfo

Returns the inter-broker endpoint.

interBrokerMoves() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats

Number of replica movements between brokers.

interBrokerMovesMB() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats

Amount of replica movements between brokers in megabytes.

INTERCEPTOR_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

interceptor.classes

INTERCEPTOR_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

interceptor.classes

INTERCEPTOR_CLASSES_DOC - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

INTERCEPTOR_CLASSES_DOC - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

InterfaceStability - Class in org.apache.kafka.common.annotation

Annotation to inform users of how much to rely on a particular package, class or method not changing over time.

InterfaceStability() - Constructor for class org.apache.kafka.common.annotation.InterfaceStability

InterfaceStability.Evolving - Annotation Type in org.apache.kafka.common.annotation

Compatibility may be broken at minor release (i.e.

InterfaceStability.Stable - Annotation Type in org.apache.kafka.common.annotation

Compatibility is maintained in major, minor and patch releases with one exception: compatibility may be broken in a major release (i.e.

InterfaceStability.Unstable - Annotation Type in org.apache.kafka.common.annotation

No guarantee is provided as to reliability or stability across any level of release granularity.

internalConfig - Variable in class org.apache.kafka.common.config.ConfigDef.ConfigKey

internalTopics() - Method in class org.apache.kafka.common.Cluster

InterruptException - Exception in org.apache.kafka.common.errors

An unchecked wrapper for InterruptedException

InterruptException(InterruptedException) - Constructor for exception org.apache.kafka.common.errors.InterruptException

InterruptException(String, InterruptedException) - Constructor for exception org.apache.kafka.common.errors.InterruptException

InterruptException(String) - Constructor for exception org.apache.kafka.common.errors.InterruptException

InvalidBrokerRemovalException - Exception in org.apache.kafka.common.errors

An exception thrown when the requested broker removal operation is invalid.

InvalidBrokerRemovalException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidBrokerRemovalException

InvalidBrokerRemovalException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidBrokerRemovalException

InvalidBrokerReplicaExclusionException - Exception in org.apache.kafka.common.errors

Thrown when the replica exclusion fails for whatever reason

InvalidBrokerReplicaExclusionException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidBrokerReplicaExclusionException

InvalidBrokerReplicaExclusionException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidBrokerReplicaExclusionException

InvalidClusterLinkException - Exception in org.apache.kafka.common.errors

Indicates that an invalid cluster link name was provided.

InvalidClusterLinkException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidClusterLinkException

InvalidClusterLinkException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidClusterLinkException

InvalidCommitOffsetSizeException - Exception in org.apache.kafka.common.errors

InvalidCommitOffsetSizeException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidCommitOffsetSizeException

InvalidCommitOffsetSizeException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidCommitOffsetSizeException

InvalidConfigurationException - Exception in org.apache.kafka.common.errors

InvalidConfigurationException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidConfigurationException

InvalidConfigurationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidConfigurationException

invalidExtensions() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback

InvalidFetchSessionEpochException - Exception in org.apache.kafka.common.errors

InvalidFetchSessionEpochException() - Constructor for exception org.apache.kafka.common.errors.InvalidFetchSessionEpochException

InvalidFetchSessionEpochException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidFetchSessionEpochException

InvalidFetchSizeException - Exception in org.apache.kafka.common.errors

InvalidFetchSizeException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidFetchSizeException

InvalidFetchSizeException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidFetchSizeException

InvalidGroupIdException - Exception in org.apache.kafka.common.errors

InvalidGroupIdException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidGroupIdException

InvalidGroupIdException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidGroupIdException

InvalidMetadataException - Exception in org.apache.kafka.common.errors

An exception that may indicate the client's metadata is out of date

InvalidMetadataException() - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException

InvalidMetadataException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException

InvalidMetadataException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException

InvalidMetadataException(Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException

InvalidOffsetException - Exception in org.apache.kafka.clients.consumer

Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured.

InvalidOffsetException(String) - Constructor for exception org.apache.kafka.clients.consumer.InvalidOffsetException

InvalidOffsetException - Exception in org.apache.kafka.common.errors

Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured.

InvalidOffsetException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidOffsetException

InvalidOffsetException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidOffsetException

InvalidPartitionsException - Exception in org.apache.kafka.common.errors

InvalidPartitionsException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidPartitionsException

InvalidPartitionsException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidPartitionsException

InvalidPidMappingException - Exception in org.apache.kafka.common.errors

InvalidPidMappingException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidPidMappingException

InvalidPrincipalTypeException - Exception in org.apache.kafka.common.errors

InvalidPrincipalTypeException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidPrincipalTypeException

InvalidPrincipalTypeException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidPrincipalTypeException

InvalidProducerEpochException - Exception in org.apache.kafka.common.errors

This exception indicates that the produce request sent to the partition leader contains a non-matching producer epoch.

InvalidProducerEpochException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidProducerEpochException

InvalidRecordException - Exception in org.apache.kafka.common

InvalidRecordException(String) - Constructor for exception org.apache.kafka.common.InvalidRecordException

InvalidRecordException(String, Throwable) - Constructor for exception org.apache.kafka.common.InvalidRecordException

InvalidReplicaAssignmentException - Exception in org.apache.kafka.common.errors

InvalidReplicaAssignmentException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidReplicaAssignmentException

InvalidReplicaAssignmentException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidReplicaAssignmentException

InvalidReplicationFactorException - Exception in org.apache.kafka.common.errors

InvalidReplicationFactorException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidReplicationFactorException

InvalidReplicationFactorException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidReplicationFactorException

InvalidRequestException - Exception in org.apache.kafka.common.errors

Thrown when a request breaks basic wire protocol rules.

InvalidRequestException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidRequestException

InvalidRequestException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidRequestException

InvalidRequiredAcksException - Exception in org.apache.kafka.common.errors

InvalidRequiredAcksException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidRequiredAcksException

InvalidSessionTimeoutException - Exception in org.apache.kafka.common.errors

InvalidSessionTimeoutException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidSessionTimeoutException

InvalidSessionTimeoutException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidSessionTimeoutException

InvalidTimestampException - Exception in org.apache.kafka.common.errors

Indicate the timestamp of a record is invalid.

InvalidTimestampException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidTimestampException

InvalidTimestampException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidTimestampException

InvalidTopicException - Exception in org.apache.kafka.common.errors

The client has attempted to perform an operation on an invalid topic.

InvalidTopicException() - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException

InvalidTopicException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException

InvalidTopicException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException

InvalidTopicException(Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException

InvalidTopicException(Set<String>) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException

InvalidTopicException(String, Set<String>) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException

invalidTopics() - Method in class org.apache.kafka.common.Cluster

invalidTopics() - Method in exception org.apache.kafka.common.errors.InvalidTopicException

InvalidTxnStateException - Exception in org.apache.kafka.common.errors

InvalidTxnStateException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidTxnStateException

InvalidTxnTimeoutException - Exception in org.apache.kafka.common.errors

The transaction coordinator returns this error code if the timeout received via the InitProducerIdRequest is larger than the `transaction.max.timeout.ms` config value.

InvalidTxnTimeoutException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidTxnTimeoutException

InvalidTxnTimeoutException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidTxnTimeoutException

InvalidUpdateVersionException - Exception in org.apache.kafka.common.errors

InvalidUpdateVersionException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidUpdateVersionException

InvalidUpdateVersionException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidUpdateVersionException

IP - Static variable in class org.apache.kafka.common.quota.ClientQuotaEntity

isBootstrapConfigured() - Method in class org.apache.kafka.common.Cluster

isCancelled() - Method in class org.apache.kafka.common.KafkaFuture

Returns true if this CompletableFuture was cancelled before it completed normally.

isComplete(long, MetricConfig) - Method in class org.apache.kafka.common.metrics.stats.SampledStat.Sample

isCompletedExceptionally() - Method in class org.apache.kafka.common.KafkaFuture

Returns true if this CompletableFuture completed exceptionally, in any way.

isDefault() - Method in class org.apache.kafka.clients.admin.ConfigEntry

Return whether the config value is the default or if it's been explicitly set.

isDefault() - Method in class org.apache.kafka.common.config.ConfigResource

Returns true if this is the default resource of a resource type.

isDone() - Method in class org.apache.kafka.common.KafkaFuture

Returns true if completed in any fashion: normally, exceptionally, or via cancellation.

isEmpty() - Method in class org.apache.kafka.clients.consumer.ConsumerRecords

isEmpty() - Method in class org.apache.kafka.common.Node

Check whether this node is empty, which may be the case if noNode() is used as a placeholder in a response payload with an error.

isFuture() - Method in class org.apache.kafka.clients.admin.ReplicaInfo

Whether this replica has been created by a AlterReplicaLogDirsRequest but not yet replaced the current replica on the broker.

isInternal() - Method in enum org.apache.kafka.clients.admin.AlterMirrorOp

isInternal() - Method in class org.apache.kafka.clients.admin.TopicDescription

Whether the topic is internal to Kafka.

isInternal() - Method in class org.apache.kafka.clients.admin.TopicListing

Whether the topic is internal to Kafka.

ISOLATION_LEVEL_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

isolation.level

ISOLATION_LEVEL_DOC - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

isolationLevel() - Method in class org.apache.kafka.clients.admin.ListOffsetsOptions

IsolationLevel - Enum in org.apache.kafka.common

isr() - Method in class org.apache.kafka.common.TopicPartitionInfo

Return the in-sync replicas of the partition.

isReadOnly() - Method in class org.apache.kafka.clients.admin.ConfigEntry

Return whether the config is read-only and cannot be updated.

isSensitive() - Method in class org.apache.kafka.clients.admin.ConfigEntry

Return whether the config value is sensitive.

isSensitive() - Method in enum org.apache.kafka.common.config.ConfigDef.Type

isShutdownScheduled() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

isSimpleConsumerGroup() - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

If consumer group is simple or not.

isSimpleConsumerGroup() - Method in class org.apache.kafka.clients.admin.ConsumerGroupListing

If Consumer Group is simple or not.

isSpecific() - Method in enum org.apache.kafka.common.resource.PatternType

isSuccessful() - Method in class org.apache.kafka.clients.admin.AlterBrokerReplicaExclusionsResult.ExclusionsResult

ISSUED_AT_CLAIM_NAME - Static variable in class org.apache.kafka.common.security.oauthbearer.secured.LoginAccessTokenValidator

issueTimestamp() - Method in class org.apache.kafka.common.security.token.delegation.TokenInformation

isTenantPrefixed() - Method in enum org.apache.kafka.common.resource.PatternType

isUnknown() - Method in class org.apache.kafka.common.acl.AccessControlEntry

Return true if this AclResource has any UNKNOWN components.

isUnknown() - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

Return true if there are any UNKNOWN components.

isUnknown() - Method in class org.apache.kafka.common.acl.AclBinding

isUnknown() - Method in class org.apache.kafka.common.acl.AclBindingFilter

isUnknown() - Method in enum org.apache.kafka.common.acl.AclOperation

Return true if this operation is UNKNOWN.

isUnknown() - Method in enum org.apache.kafka.common.acl.AclPermissionType

Return true if this permission type is UNKNOWN.

isUnknown() - Method in enum org.apache.kafka.common.resource.PatternType

isUnknown() - Method in class org.apache.kafka.common.resource.Resource

Return true if this Resource has any UNKNOWN components.

isUnknown() - Method in class org.apache.kafka.common.resource.ResourcePattern

isUnknown() - Method in class org.apache.kafka.common.resource.ResourcePatternFilter

isUnknown() - Method in enum org.apache.kafka.common.resource.ResourceType

Return whether this resource type is UNKNOWN.

isUpperBound() - Method in class org.apache.kafka.common.metrics.Quota

isValidEntityType(String) - Static method in class org.apache.kafka.common.quota.ClientQuotaEntity

iterations() - Method in class org.apache.kafka.clients.admin.ScramCredentialInfo

iterations() - Method in class org.apache.kafka.common.security.scram.ScramCredential

Number of iterations used to process this credential using the SCRAM algorithm.

iterator() - Method in class org.apache.kafka.clients.consumer.ConsumerRecords

J

JaasOptionsUtils - Class in org.apache.kafka.common.security.oauthbearer.secured

JaasOptionsUtils is a utility class to perform logic for the JAAS options and is separated out here for easier, more direct testing.

JaasOptionsUtils(Map<String, Object>) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.JaasOptionsUtils

JMX_IGNORE_TAG - Static variable in class org.apache.kafka.common.metrics.JmxReporter

JmxReporter - Class in org.apache.kafka.common.metrics

Register metrics in JMX as dynamic mbeans based on the metric names

JmxReporter() - Constructor for class org.apache.kafka.common.metrics.JmxReporter

JmxReporter(String) - Constructor for class org.apache.kafka.common.metrics.JmxReporter

Deprecated.

Since 2.6.0. Use JmxReporter() Initialize JmxReporter with JmxReporter.contextChange(MetricsContext) Populate prefix by adding _namespace/prefix key value pair to MetricsContext

JwksFileVerificationKeyResolver - Class in org.apache.kafka.common.security.oauthbearer.secured

JwksFileVerificationKeyResolver is a VerificationKeyResolver implementation that will load the JWKS from the given file system directory.

JwksFileVerificationKeyResolver(Path) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.JwksFileVerificationKeyResolver

K

KAFKA_SSL_ENGINE_FACTORY_CLASS - Static variable in class org.apache.kafka.common.config.SslConfigs

KafkaAdminClient - Class in org.apache.kafka.clients.admin

The default implementation of Admin.

KafkaConsumer<K,V> - Class in org.apache.kafka.clients.consumer

A client that consumes records from a Kafka cluster.

KafkaConsumer(Map<String, Object>) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer

A consumer is instantiated by providing a set of key-value pairs as configuration.

KafkaConsumer(Properties) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer

A consumer is instantiated by providing a Properties object as configuration.

KafkaConsumer(Properties, Deserializer<K>, Deserializer<V>) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer

A consumer is instantiated by providing a Properties object as configuration, and a key and a value Deserializer.

KafkaConsumer(Map<String, Object>, Deserializer<K>, Deserializer<V>) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer

A consumer is instantiated by providing a set of key-value pairs as configuration, and a key and a value Deserializer.

KafkaException - Exception in org.apache.kafka.common

The base class of all other Kafka exceptions

KafkaException(String, Throwable) - Constructor for exception org.apache.kafka.common.KafkaException

KafkaException(String) - Constructor for exception org.apache.kafka.common.KafkaException

KafkaException(Throwable) - Constructor for exception org.apache.kafka.common.KafkaException

KafkaException() - Constructor for exception org.apache.kafka.common.KafkaException

KafkaFuture<T> - Class in org.apache.kafka.common

A flexible future which supports call chaining and other asynchronous programming patterns.

KafkaFuture() - Constructor for class org.apache.kafka.common.KafkaFuture

KafkaFuture.BaseFunction<A,B> - Interface in org.apache.kafka.common

A function which takes objects of type A and returns objects of type B.

KafkaFuture.BiConsumer<A,B> - Interface in org.apache.kafka.common

A consumer of two different types of object.

KafkaFuture.Function<A,B> - Class in org.apache.kafka.common

Deprecated.

Since Kafka 3.0. Use the KafkaFuture.BaseFunction functional interface.

KafkaMetric - Class in org.apache.kafka.common.metrics

KafkaMetric(Object, MetricName, MetricValueProvider<?>, MetricConfig, Time) - Constructor for class org.apache.kafka.common.metrics.KafkaMetric

KafkaMetricsContext - Class in org.apache.kafka.common.metrics

A implementation of MetricsContext, it encapsulates required metrics context properties for Kafka services and clients

KafkaMetricsContext(String) - Constructor for class org.apache.kafka.common.metrics.KafkaMetricsContext

Create a MetricsContext with namespace, no service or client properties

KafkaMetricsContext(String, Map<String, ?>) - Constructor for class org.apache.kafka.common.metrics.KafkaMetricsContext

Create a MetricsContext with namespace, service or client properties

KafkaPrincipal - Class in org.apache.kafka.common.security.auth

Principals in Kafka are defined by a type and a name.

KafkaPrincipal(String, String) - Constructor for class org.apache.kafka.common.security.auth.KafkaPrincipal

KafkaPrincipal(String, String, boolean) - Constructor for class org.apache.kafka.common.security.auth.KafkaPrincipal

KafkaPrincipalBuilder - Interface in org.apache.kafka.common.security.auth

Pluggable principal builder interface which supports both SSL authentication through SslAuthenticationContext and SASL through SaslAuthenticationContext.

KafkaPrincipalSerde - Interface in org.apache.kafka.common.security.auth

Serializer/Deserializer interface for KafkaPrincipal for the purpose of inter-broker forwarding.

KafkaProducer<K,V> - Class in org.apache.kafka.clients.producer

A Kafka client that publishes records to the Kafka cluster.

KafkaProducer(Map<String, Object>) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer

A producer is instantiated by providing a set of key-value pairs as configuration.

KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer

A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.

KafkaProducer(Properties) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer

A producer is instantiated by providing a set of key-value pairs as configuration.

KafkaProducer(Properties, Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer

A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.

KafkaStorageException - Exception in org.apache.kafka.common.errors

Miscellaneous disk-related IOException occurred when handling a request.

KafkaStorageException() - Constructor for exception org.apache.kafka.common.errors.KafkaStorageException

KafkaStorageException(String) - Constructor for exception org.apache.kafka.common.errors.KafkaStorageException

KafkaStorageException(Throwable) - Constructor for exception org.apache.kafka.common.errors.KafkaStorageException

KafkaStorageException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.KafkaStorageException

key() - Method in class org.apache.kafka.clients.consumer.ConsumerRecord

The key (or null if no key is specified)

key() - Method in class org.apache.kafka.clients.producer.ProducerRecord

key() - Method in interface org.apache.kafka.common.header.Header

key() - Method in class org.apache.kafka.common.quota.ClientQuotaAlteration.Op

KEY_DESERIALIZER_CLASS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

key.deserializer

KEY_DESERIALIZER_CLASS_DOC - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

KEY_SCHEMA_VALIDATION_CONFIG - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

KEY_SCHEMA_VALIDATION_DOC - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

KEY_SERIALIZER_CLASS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

key.serializer

KEY_SERIALIZER_CLASS_DOC - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

KEY_SUBJECT_NAME_STRATEGY_CONFIG - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

KEY_SUBJECT_NAME_STRATEGY_DOC - Static variable in class org.apache.kafka.common.config.ConfluentTopicConfig

keystore() - Method in interface org.apache.kafka.common.security.auth.SslEngineFactory

Returns keystore configured for this factory.

L

lastCaughtUpTimestamp() - Method in class org.apache.kafka.clients.admin.QuorumInfo.ReplicaState

Return the last millisecond timestamp at which this replica was known to be caught up with the leader.

lastFetchTimestamp() - Method in class org.apache.kafka.clients.admin.QuorumInfo.ReplicaState

Return the last millisecond timestamp that the leader received a fetch from this replica.

lastHeader(String) - Method in interface org.apache.kafka.common.header.Headers

Returns just one (the very last) header for the given key, if present.

lastPollTimeout() - Method in class org.apache.kafka.clients.consumer.MockConsumer

lastSequence() - Method in class org.apache.kafka.clients.admin.ProducerState

lastTimestamp() - Method in class org.apache.kafka.clients.admin.ProducerState

lastUpdateTimeMs() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription

The timestamp at which this broker addition operation was last updated

lastUpdateTimeMs() - Method in class org.apache.kafka.clients.admin.BrokerRemovalDescription

The timestamp at which this broker removal operation was last updated

lastWindowMs - Variable in class org.apache.kafka.common.metrics.stats.SampledStat.Sample

latest() - Static method in class org.apache.kafka.clients.admin.OffsetSpec

Used to retrieve the latest offset of a partition

LatestSpec() - Constructor for class org.apache.kafka.clients.admin.OffsetSpec.LatestSpec

leader() - Method in class org.apache.kafka.common.PartitionInfo

The node id of the node currently acting as a leader for this partition or null if there is no leader

leader() - Method in class org.apache.kafka.common.TopicPartitionInfo

Return the leader of the partition or null if there is none.

leaderEpoch() - Method in class org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo

leaderEpoch() - Method in class org.apache.kafka.clients.admin.PartitionResult

leaderEpoch() - Method in class org.apache.kafka.clients.admin.QuorumInfo

leaderEpoch() - Method in class org.apache.kafka.clients.consumer.ConsumerRecord

Get the leader epoch for the record if available

leaderEpoch() - Method in class org.apache.kafka.clients.consumer.OffsetAndMetadata

Get the leader epoch of the previously consumed record (if one is known).

leaderEpoch() - Method in class org.apache.kafka.clients.consumer.OffsetAndTimestamp

Get the leader epoch corresponding to the offset that was found (if one exists).

leaderFor(TopicPartition) - Method in class org.apache.kafka.common.Cluster

Get the current leader for the given topic-partition

leaderId() - Method in class org.apache.kafka.clients.admin.PartitionResult

leaderId() - Method in class org.apache.kafka.clients.admin.QuorumInfo

leaderNetworkInKBps() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Inbound traffic from replicas that it's leader of.

LeaderNotAvailableException - Exception in org.apache.kafka.common.errors

There is no currently available leader for the given partition (either because a leadership election is in progress or because all replicas are down).

LeaderNotAvailableException(String) - Constructor for exception org.apache.kafka.common.errors.LeaderNotAvailableException

LeaderNotAvailableException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.LeaderNotAvailableException

leaderReplicas() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources

Number of leader replicas in the cluster.

leaders() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerStats

Number of replicas that it's a leader of.

leadersForTopic(String) - Method in class org.apache.kafka.common.Cluster

Get the list of leaders for this topic

leadershipMoves() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats

Number of replica leadership moves.

leadershipPriority() - Method in class org.apache.kafka.clients.admin.BrokerLeadershipPriorityResult

Indicates the broker's new leadership priority enum.

lifetimeMs() - Method in interface org.apache.kafka.common.security.oauthbearer.OAuthBearerToken

The token's lifetime, expressed as the number of milliseconds since the epoch, as per RFC 6749 Section 1.4

lifetimeMs() - Method in class org.apache.kafka.common.security.oauthbearer.secured.BasicOAuthBearerToken

The token's lifetime, expressed as the number of milliseconds since the epoch, as per RFC 6749 Section 1.4

LinearBinScheme(int, double) - Constructor for class org.apache.kafka.common.metrics.stats.Histogram.LinearBinScheme

Create a linear bin scheme with the specified number of bins and the maximum value to be counted in the bins.

LINGER_MS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

linger.ms

linkId() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

Deprecated.

linkId() - Method in class org.apache.kafka.clients.admin.MirrorTopicDescription

Deprecated.

linkMode() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

Link mode.

linkName() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

The link name for the cluster link.

linkName() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

The link name for the cluster link.

linkName() - Method in class org.apache.kafka.clients.admin.ListMirrorsOptions

The link name whose mirrors should be listed, or all if empty.

linkName(Optional<String>) - Method in class org.apache.kafka.clients.admin.ListMirrorsOptions

The link name whose mirrors should be listed, or all if empty.

linkName() - Method in class org.apache.kafka.clients.admin.MirrorTopicDescription

The name of the cluster link for the mirror topic.

linkName() - Method in class org.apache.kafka.clients.admin.NewClusterLink

The name of the cluster link to be created.

linkName() - Method in class org.apache.kafka.clients.admin.NewMirrorTopic

The name of the cluster link over which the topic will mirror from.

linkNames() - Method in class org.apache.kafka.clients.admin.DescribeClusterLinksOptions

Names of the cluster links to include in the response, otherwise if empty, then all cluster links are included.

linkNames(Collection<String>) - Method in class org.apache.kafka.clients.admin.DescribeClusterLinksOptions

Sets the names of the cluster links to include in the response, otherwise if null, then sets all cluster links to be listed.

linkNames() - Method in class org.apache.kafka.clients.admin.ListClusterLinksOptions

Names of the cluster links to include in the response, otherwise if empty, then all cluster links are listed.

linkNames(Optional<Collection<String>>) - Method in class org.apache.kafka.clients.admin.ListClusterLinksOptions

Sets the names of the cluster links to include in the response, otherwise if empty, then sets all cluster links to be listed.

linkState() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

listClusterLinks(ListClusterLinksOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Lists the cluster links.

listClusterLinks(ListClusterLinksOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListClusterLinksOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin.listClusterLinks(ListClusterLinksOptions).

ListClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.ListClusterLinksOptions

ListClusterLinksResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.listClusterLinks(ListClusterLinksOptions).

ListClusterLinksResult(KafkaFuture<Collection<ClusterLinkListing>>) - Constructor for class org.apache.kafka.clients.admin.ListClusterLinksResult

listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List the consumer group offsets available in the cluster.

listConsumerGroupOffsets(String) - Method in interface org.apache.kafka.clients.admin.Admin

List the consumer group offsets available in the cluster with the default options.

listConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List the consumer group offsets available in the cluster for the specified consumer groups.

listConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>) - Method in interface org.apache.kafka.clients.admin.Admin

List the consumer group offsets available in the cluster for the specified groups with the default options.

listConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListConsumerGroupOffsetsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.listConsumerGroupOffsets(java.util.Map) and Admin.listConsumerGroupOffsets(String).

ListConsumerGroupOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions

ListConsumerGroupOffsetsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.listConsumerGroupOffsets(Map) and Admin.listConsumerGroupOffsets(String) call.

ListConsumerGroupOffsetsSpec - Class in org.apache.kafka.clients.admin

Specification of consumer group offsets to list using Admin.listConsumerGroupOffsets(java.util.Map).

ListConsumerGroupOffsetsSpec() - Constructor for class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsSpec

listConsumerGroups(ListConsumerGroupsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List the consumer groups available in the cluster.

listConsumerGroups() - Method in interface org.apache.kafka.clients.admin.Admin

List the consumer groups available in the cluster with the default options.

listConsumerGroups(ListConsumerGroupsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListConsumerGroupsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.listConsumerGroups().

ListConsumerGroupsOptions() - Constructor for class org.apache.kafka.clients.admin.ListConsumerGroupsOptions

ListConsumerGroupsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.listConsumerGroups() call.

ListDeserializer<Inner> - Class in org.apache.kafka.common.serialization

ListDeserializer() - Constructor for class org.apache.kafka.common.serialization.ListDeserializer

ListDeserializer(Class<L>, Deserializer<Inner>) - Constructor for class org.apache.kafka.common.serialization.ListDeserializer

listenerName() - Method in class org.apache.kafka.common.Endpoint

Returns the listener name of this endpoint.

listenerName() - Method in interface org.apache.kafka.common.security.auth.AuthenticationContext

Name of the listener used for the connection

listenerName() - Method in class org.apache.kafka.common.security.auth.PlaintextAuthenticationContext

listenerName() - Method in class org.apache.kafka.common.security.auth.SaslAuthenticationContext

listenerName() - Method in class org.apache.kafka.common.security.auth.SslAuthenticationContext

listenerName() - Method in interface org.apache.kafka.server.authorizer.AuthorizableRequestContext

Returns name of listener on which request was received.

ListenerNotFoundException - Exception in org.apache.kafka.common.errors

The leader does not have an endpoint corresponding to the listener on which metadata was requested.

ListenerNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.ListenerNotFoundException

ListenerNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.ListenerNotFoundException

listings() - Method in class org.apache.kafka.clients.admin.ListTopicsResult

Return a future which yields a collection of TopicListing objects.

listInternal(boolean) - Method in class org.apache.kafka.clients.admin.ListTopicsOptions

Set whether we should list internal topics.

listMirrors(ListMirrorsOptions) - Method in interface org.apache.kafka.clients.admin.ConfluentAdmin

Lists the mirrored topics, i.e.

listMirrors(ListMirrorsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListMirrorsOptions - Class in org.apache.kafka.clients.admin

Options for ConfluentAdmin.listMirrors(ListMirrorsOptions).

ListMirrorsOptions() - Constructor for class org.apache.kafka.clients.admin.ListMirrorsOptions

ListMirrorsResult - Class in org.apache.kafka.clients.admin

The result of ConfluentAdmin.listMirrors(ListMirrorsOptions).

ListMirrorsResult(KafkaFuture<Collection<String>>) - Constructor for class org.apache.kafka.clients.admin.ListMirrorsResult

listOffsets(Map<TopicPartition, OffsetSpec>) - Method in interface org.apache.kafka.clients.admin.Admin

List offset for the specified partitions and OffsetSpec.

listOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List offset for the specified partitions.

listOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListOffsetsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.listOffsets(Map).

ListOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.ListOffsetsOptions

ListOffsetsOptions(IsolationLevel) - Constructor for class org.apache.kafka.clients.admin.ListOffsetsOptions

ListOffsetsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.listOffsets(Map) call.

ListOffsetsResult(Map<TopicPartition, KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo>>) - Constructor for class org.apache.kafka.clients.admin.ListOffsetsResult

ListOffsetsResult.ListOffsetsResultInfo - Class in org.apache.kafka.clients.admin

ListOffsetsResultInfo(long, long, Optional<Integer>) - Constructor for class org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo

listPartitionReassignments() - Method in interface org.apache.kafka.clients.admin.Admin

List all of the current partition reassignments This is a convenience method for Admin.listPartitionReassignments(ListPartitionReassignmentsOptions) with default options.

listPartitionReassignments(Set<TopicPartition>) - Method in interface org.apache.kafka.clients.admin.Admin

List the current reassignments for the given partitions This is a convenience method for Admin.listPartitionReassignments(Set, ListPartitionReassignmentsOptions) with default options.

listPartitionReassignments(Set<TopicPartition>, ListPartitionReassignmentsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List the current reassignments for the given partitions

listPartitionReassignments(ListPartitionReassignmentsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List all of the current partition reassignments

listPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

listPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListPartitionReassignmentsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.listPartitionReassignments(ListPartitionReassignmentsOptions) The API of this class is evolving.

ListPartitionReassignmentsOptions() - Constructor for class org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions

ListPartitionReassignmentsResult - Class in org.apache.kafka.clients.admin

The result of Admin.listPartitionReassignments(ListPartitionReassignmentsOptions).

ListSerde(Class<L>, Serde<Inner>) - Static method in class org.apache.kafka.common.serialization.Serdes

ListSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.ListSerde

ListSerde(Class<L>, Serde<Inner>) - Constructor for class org.apache.kafka.common.serialization.Serdes.ListSerde

ListSerializer<Inner> - Class in org.apache.kafka.common.serialization

ListSerializer() - Constructor for class org.apache.kafka.common.serialization.ListSerializer

ListSerializer(Serializer<Inner>) - Constructor for class org.apache.kafka.common.serialization.ListSerializer

listTopics() - Method in interface org.apache.kafka.clients.admin.Admin

List the topics available in the cluster with the default options.

listTopics(ListTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List the topics available in the cluster.

listTopics(ListTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

listTopics() - Method in interface org.apache.kafka.clients.consumer.Consumer

listTopics(Duration) - Method in interface org.apache.kafka.clients.consumer.Consumer

listTopics() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get metadata about partitions for all topics that the user is authorized to view.

listTopics(Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get metadata about partitions for all topics that the user is authorized to view.

listTopics() - Method in class org.apache.kafka.clients.consumer.MockConsumer

listTopics(Duration) - Method in class org.apache.kafka.clients.consumer.MockConsumer

ListTopicsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.listTopics().

ListTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.ListTopicsOptions

ListTopicsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.listTopics() call.

listTransactions() - Method in interface org.apache.kafka.clients.admin.Admin

List active transactions in the cluster.

listTransactions(ListTransactionsOptions) - Method in interface org.apache.kafka.clients.admin.Admin

List active transactions in the cluster.

listTransactions(ListTransactionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

ListTransactionsOptions - Class in org.apache.kafka.clients.admin

Options for Admin.listTransactions().

ListTransactionsOptions() - Constructor for class org.apache.kafka.clients.admin.ListTransactionsOptions

ListTransactionsResult - Class in org.apache.kafka.clients.admin

The result of the Admin.listTransactions() call.

LOCAL_LOG_RETENTION_BYTES_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

LOCAL_LOG_RETENTION_BYTES_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

LOCAL_LOG_RETENTION_MS_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

LOCAL_LOG_RETENTION_MS_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

localClusterId() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription

localClusterId() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing

log - Static variable in class org.apache.kafka.common.DelegatingReconfigurable

LogDirDescription - Class in org.apache.kafka.clients.admin

A description of a log directory on a particular broker.

LogDirDescription(ApiException, Map<TopicPartition, ReplicaInfo>) - Constructor for class org.apache.kafka.clients.admin.LogDirDescription

LogDirDescription(ApiException, Map<TopicPartition, ReplicaInfo>, long, long) - Constructor for class org.apache.kafka.clients.admin.LogDirDescription

LogDirNotFoundException - Exception in org.apache.kafka.common.errors

Thrown when a request is made for a log directory that is not present on the broker

LogDirNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.LogDirNotFoundException

LogDirNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.LogDirNotFoundException

LogDirNotFoundException(Throwable) - Constructor for exception org.apache.kafka.common.errors.LogDirNotFoundException

logEndOffset() - Method in class org.apache.kafka.clients.admin.QuorumInfo.ReplicaState

Return the logEndOffset known by the leader for this replica.

logIfAllowed() - Method in class org.apache.kafka.server.authorizer.Action

Indicates if audit logs tracking ALLOWED access should include this action if result is ALLOWED.

logIfDenied() - Method in class org.apache.kafka.server.authorizer.Action

Indicates if audit logs tracking DENIED access should include this action if result is DENIED.

Login - Interface in org.apache.kafka.common.security.auth

Login interface for authentication.

login() - Method in interface org.apache.kafka.common.security.auth.Login

Performs login for each login module specified for the login context of this instance.

login() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule

login() - Method in class org.apache.kafka.common.security.plain.PlainLoginModule

login() - Method in class org.apache.kafka.common.security.scram.ScramLoginModule

LoginAccessTokenValidator - Class in org.apache.kafka.common.security.oauthbearer.secured

LoginAccessTokenValidator is an implementation of AccessTokenValidator that is used by the client to perform some rudimentary validation of the JWT access token that is received as part of the response from posting the client credentials to the OAuth/OIDC provider's token endpoint.

LoginAccessTokenValidator(String, String) - Constructor for class org.apache.kafka.common.security.oauthbearer.secured.LoginAccessTokenValidator

Creates a new LoginAccessTokenValidator that will be used by the client for lightweight validation of the JWT.

LogLevelConfig - Class in org.apache.kafka.common.config

This class holds definitions for log level configurations related to Kafka's application logging.

LogLevelConfig() - Constructor for class org.apache.kafka.common.config.LogLevelConfig

logMessage() - Method in exception org.apache.kafka.common.errors.AuthenticationException

This message is for internal logging and should not be returned to clients.

logout() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule

logout() - Method in class org.apache.kafka.common.security.plain.PlainLoginModule

logout() - Method in class org.apache.kafka.common.security.scram.ScramLoginModule

LogTruncationException - Exception in org.apache.kafka.clients.consumer

In the event of an unclean leader election, the log will be truncated, previously committed data will be lost, and new data will be written over these offsets.

LogTruncationException(String, Map<TopicPartition, Long>, Map<TopicPartition, OffsetAndMetadata>) - Constructor for exception org.apache.kafka.clients.consumer.LogTruncationException

logUnused() - Method in class org.apache.kafka.common.config.AbstractConfig

Log warnings for any unused configurations

Long() - Static method in class org.apache.kafka.common.serialization.Serdes

A serde for nullable Long type.

LongDeserializer - Class in org.apache.kafka.common.serialization

LongDeserializer() - Constructor for class org.apache.kafka.common.serialization.LongDeserializer

LongSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.LongSerde

LongSerializer - Class in org.apache.kafka.common.serialization

LongSerializer() - Constructor for class org.apache.kafka.common.serialization.LongSerializer

lowerBound(double) - Static method in class org.apache.kafka.common.metrics.Quota

lowWatermark() - Method in class org.apache.kafka.clients.admin.DeletedRecords

Return the "low watermark" for the topic partition on which the deletion was executed

lowWatermarks() - Method in class org.apache.kafka.clients.admin.DeleteRecordsResult

Return a map from topic partition to futures which can be used to check the status of individual deletions.

M

main(String[]) - Static method in class org.apache.kafka.clients.admin.AdminClientConfig

main(String[]) - Static method in class org.apache.kafka.clients.consumer.ConsumerConfig

main(String[]) - Static method in class org.apache.kafka.clients.producer.ProducerConfig

map() - Method in class org.apache.kafka.common.security.auth.SaslExtensions

Returns an immutable map of the extension names and their values

match() - Method in class org.apache.kafka.common.quota.ClientQuotaFilterComponent

matches(AccessControlEntry) - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

Returns true if this filter matches the given AccessControlEntry.

matches(AclBinding) - Method in class org.apache.kafka.common.acl.AclBindingFilter

Return true if the resource filter matches the binding's resource and the entry filter matches binding's entry.

matches(ResourcePattern) - Method in class org.apache.kafka.common.resource.ResourcePatternFilter

matchesAtMostOne() - Method in class org.apache.kafka.common.acl.AccessControlEntryFilter

Returns true if this filter could only match one ACE -- in other words, if there are no ANY or UNKNOWN fields.

matchesAtMostOne() - Method in class org.apache.kafka.common.acl.AclBindingFilter

Return true if the resource and entry filters can only match one ACE.

matchesAtMostOne() - Method in class org.apache.kafka.common.resource.ResourcePatternFilter

Max - Class in org.apache.kafka.common.metrics.stats

A SampledStat that gives the max over its samples.

Max() - Constructor for class org.apache.kafka.common.metrics.stats.Max

MAX_BLOCK_MS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

max.block.ms

MAX_COMPACTION_LAG_MS_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

MAX_COMPACTION_LAG_MS_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

max.in.flight.requests.per.connection

MAX_MESSAGE_BYTES_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

MAX_MESSAGE_BYTES_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

MAX_PARTITION_FETCH_BYTES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

max.partition.fetch.bytes

MAX_POLL_INTERVAL_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

max.poll.interval.ms

MAX_POLL_RECORDS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

max.poll.records

MAX_RECORDING_LEVEL_KEY - Static variable in enum org.apache.kafka.common.metrics.Sensor.RecordingLevel

MAX_REQUEST_SIZE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

max.request.size

maxlifeTimeMs(long) - Method in class org.apache.kafka.clients.admin.CreateDelegationTokenOptions

maxlifeTimeMs() - Method in class org.apache.kafka.clients.admin.CreateDelegationTokenOptions

maxResources() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStats

Cluster-wide statistics for maximum resource usages.

maxTimestamp() - Static method in class org.apache.kafka.clients.admin.OffsetSpec

Used to retrieve the offset with the largest timestamp of a partition as message timestamps can be specified client side this may not match the log end offset returned by LatestSpec

maxTimestamp() - Method in class org.apache.kafka.common.security.token.delegation.TokenInformation

MaxTimestampSpec() - Constructor for class org.apache.kafka.clients.admin.OffsetSpec.MaxTimestampSpec

maxVersion() - Method in class org.apache.kafka.clients.admin.SupportedVersionRange

maxVersionLevel() - Method in class org.apache.kafka.clients.admin.FeatureUpdate

maxVersionLevel() - Method in class org.apache.kafka.clients.admin.FinalizedVersionRange

maybeExpediteRefresh(String) - Method in class org.apache.kafka.common.security.oauthbearer.secured.RefreshingHttpsJwks

maybeExpediteRefresh is a public method that will trigger a refresh of the JWKS cache if all of the following conditions are met: The given keyId parameter is <e; the RefreshingHttpsJwks.MISSING_KEY_ID_MAX_KEY_LENGTH The key isn't in the process of being expedited already

measurable() - Method in class org.apache.kafka.common.metrics.KafkaMetric

Measurable - Interface in org.apache.kafka.common.metrics

A measurable quantity that can be registered as a metric

MeasurableStat - Interface in org.apache.kafka.common.metrics

A MeasurableStat is a Stat that is also Measurable (i.e.

measure(MetricConfig, long) - Method in interface org.apache.kafka.common.metrics.Measurable

Measure this quantity and return the result as a double

measure(MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.CumulativeSum

measure(MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Rate

measure(MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.SampledStat

measure(MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.TokenBucket

measure(MetricConfig, long) - Method in class org.apache.kafka.common.metrics.stats.Value

mechanism() - Method in class org.apache.kafka.clients.admin.ScramCredentialInfo

mechanism() - Method in class org.apache.kafka.clients.admin.UserScramCredentialDeletion

mechanismName() - Method in enum org.apache.kafka.clients.admin.ScramMechanism

MemberAssignment - Class in org.apache.kafka.clients.admin

A description of the assignments of a specific group member.

MemberAssignment(Set<TopicPartition>) - Constructor for class org.apache.kafka.clients.admin.MemberAssignment

Creates an instance with the specified parameters.

memberData(ConsumerPartitionAssignor.Subscription) - Method in class org.apache.kafka.clients.consumer.CooperativeStickyAssignor

memberData(ConsumerPartitionAssignor.Subscription) - Method in class org.apache.kafka.clients.consumer.StickyAssignor

MemberDescription - Class in org.apache.kafka.clients.admin

A detailed description of a single group instance in the cluster.

MemberDescription(String, Optional<String>, String, String, MemberAssignment) - Constructor for class org.apache.kafka.clients.admin.MemberDescription

MemberDescription(String, String, String, MemberAssignment) - Constructor for class org.apache.kafka.clients.admin.MemberDescription

memberId() - Method in class org.apache.kafka.clients.consumer.ConsumerGroupMetadata

MemberIdRequiredException - Exception in org.apache.kafka.common.errors

MemberIdRequiredException(String) - Constructor for exception org.apache.kafka.common.errors.MemberIdRequiredException

MemberIdRequiredException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.MemberIdRequiredException

memberResult(MemberToRemove) - Method in class org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult

Returns the selected member future.

members() - Method in class org.apache.kafka.clients.admin.ConsumerGroupDescription

A list of the members of the consumer group.

members() - Method in class org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions

MemberToRemove - Class in org.apache.kafka.clients.admin

A struct containing information about the member to be removed.

MemberToRemove(String) - Constructor for class org.apache.kafka.clients.admin.MemberToRemove

MESSAGE_DOWNCONVERSION_ENABLE_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

MESSAGE_DOWNCONVERSION_ENABLE_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

MESSAGE_FORMAT_VERSION_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

Deprecated.

since 3.0, removal planned in 4.0. The default value for this config is appropriate for most situations.

MESSAGE_FORMAT_VERSION_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

Deprecated.

since 3.0, removal planned in 4.0. The default value for this config is appropriate for most situations.

MESSAGE_TIMESTAMP_DIFFERENCE_MAX_MS_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

MESSAGE_TIMESTAMP_DIFFERENCE_MAX_MS_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

MESSAGE_TIMESTAMP_TYPE_CONFIG - Static variable in class org.apache.kafka.common.config.TopicConfig

MESSAGE_TIMESTAMP_TYPE_DOC - Static variable in class org.apache.kafka.common.config.TopicConfig

MessageFormatter - Interface in org.apache.kafka.common

This interface allows to define Formatters that can be used to parse and format records read by a Consumer instance for display.

metadata() - Method in class org.apache.kafka.clients.consumer.OffsetAndMetadata

METADATA_MAX_AGE_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

METADATA_MAX_AGE_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

metadata.max.age.ms

METADATA_MAX_AGE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

metadata.max.age.ms

METADATA_MAX_IDLE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

metadata.max.idle.ms

METADATA_TOPIC_ID - Static variable in class org.apache.kafka.common.Uuid

A UUID for the metadata topic in KRaft mode.

Meter - Class in org.apache.kafka.common.metrics.stats

A compound stat that includes a rate metric and a cumulative total metric.

Meter(MetricName, MetricName) - Constructor for class org.apache.kafka.common.metrics.stats.Meter

Construct a Meter with seconds as time unit

Meter(TimeUnit, MetricName, MetricName) - Constructor for class org.apache.kafka.common.metrics.stats.Meter

Construct a Meter with provided time unit

Meter(SampledStat, MetricName, MetricName) - Constructor for class org.apache.kafka.common.metrics.stats.Meter

Construct a Meter with seconds as time unit

Meter(TimeUnit, SampledStat, MetricName, MetricName) - Constructor for class org.apache.kafka.common.metrics.stats.Meter

Construct a Meter with provided time unit

Metric - Interface in org.apache.kafka.common

A metric tracked for monitoring purposes.

metric(MetricName) - Method in class org.apache.kafka.common.metrics.Metrics

metric() - Method in exception org.apache.kafka.common.metrics.QuotaViolationException

METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig

METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig

metric.reporters

METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig

metric.reporters

metricChange(KafkaMetric) - Method in class org.apache.kafka.common.metrics.JmxReporter

metricChange(KafkaMetric) - Method in interface org.apache.kafka.common.metrics.MetricsReporter

This is called whenever a metric is updated or added

MetricConfig - Class in org.apache.kafka.common.metrics

Configuration values for metrics

MetricConfig() - Constructor for class org.apache.kafka.common.metrics.MetricConfig

metricInstance(MetricNameTemplate, String...) - Method in class org.apache.kafka.common.metrics.Metrics

metricInstance(MetricNameTemplate, Map<String, String>) - Method in class org.apache.kafka.common.metrics.Metrics

metricName() - Method in interface org.apache.kafka.common.Metric

A name for this metric

MetricName - Class in org.apache.kafka.common

The MetricName class encapsulates a metric's name, logical group and its related attributes.

MetricName(String, String, String, Map<String, String>) - Constructor for class org.apache.kafka.common.MetricName

Please create MetricName by method Metrics.metricName(String, String, String, Map)

metricName() - Method in class org.apache.kafka.common.metrics.KafkaMetric

metricName(String, String, String, Map<String, String>) - Method in class org.apache.kafka.common.metrics.Metrics

Create a MetricName with the given name, group, description and tags, plus default tags specified in the metric configuration.

metricName(String, String, String) - Method in class org.apache.kafka.common.metrics.Metrics

Create a MetricName with the given name, group, description, and default tags specified in the metric configuration.

metricName(String, String) - Method in class org.apache.kafka.common.metrics.Metrics

Create a MetricName with the given name, group and default tags specified in the metric configuration.

metricName(String, String, String, String...) - Method in class org.apache.kafka.common.metrics.Metrics

Create a MetricName with the given name, group, description, and keyValue as tags, plus default tags specified in the metric configuration.

metricName(String, String, Map<String, String>) - Method in class org.apache.kafka.common.metrics.Metrics

Create a MetricName with the given name, group and tags, plus default tags specified in the metric configuration.

MetricNameTemplate - Class in org.apache.kafka.common

A template for a MetricName.

MetricNameTemplate(String, String, String, Set<String>) - Constructor for class org.apache.kafka.common.MetricNameTemplate

Create a new template.

MetricNameTemplate(String, String, String, String...) - Constructor for class org.apache.kafka.common.MetricNameTemplate

Create a new template.

metricRemoval(KafkaMetric) - Method in class org.apache.kafka.common.metrics.JmxReporter

metricRemoval(KafkaMetric) - Method in interface org.apache.kafka.common.metrics.MetricsReporter

This is called whenever a metric is removed

metrics() - Method in interface org.apache.kafka.clients.admin.Admin

Get the metrics kept by the adminClient

metrics() - Method in class org.apache.kafka.clients.admin.KafkaAdminClient

metrics() - Method in interface org.apache.kafka.clients.consumer.Consumer

metrics() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer

Get the metrics kept by the consumer

metrics() - Method in class org.apache.kafka.clients.consumer.MockConsumer

metrics() - Method in class org.apache.kafka.clients.producer.KafkaProducer

Get the full set of internal metrics maintained by the producer.

metrics() - Method in class org.apache.kafka.clients.producer.MockProducer

metrics() - Method in interface org.apache.kafka.clients.producer.Producer

See KafkaProducer.metrics()

Metrics - Class in org.apache.kafka.common.metrics

A registry of sensors and metrics.

Metrics() - Constructor for class org.apache.kafka.common.metrics.Metrics

Create a metrics repository with no metric reporters and default configuration.

Metrics(Time) - Constructor for class org.apache.kafka.common.metrics.Metrics

Create a metrics repository with no metric reporters and default configuration.

Metrics(MetricConfig, Time) - Constructor for class org.apache.kafka.common.metrics.Metrics

Create a metrics repository with no metric reporters and the given default configuration.

Metrics(MetricConfig) - Constructor for class org.apache.kafka.common.metrics.Metrics

Create a metrics repository with no reporters and the given default config.

Metrics(MetricConfig, List<MetricsReporter>, Time) - Constructor for class org.apache.kafka.common.metrics.Metrics

Create a metrics repository with a default config and the given metric reporters.

Metrics(MetricConfig, List<MetricsReporter>, Time, MetricsContext) - Constructor for class org.apache.kafka.common.metrics.Metrics

Create a metrics repository with a default config, metric reporters and metric context Expiration of Sensors is disabled.

Metrics(MetricConfig, List<MetricsReporter>, Time, boolean) - Constructor for class org.a