- 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.ForwardingAdmin
-
- 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
-
- 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
-
- 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.
- 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.
- acls(AclBindingFilter, AclState) - Method in interface org.apache.kafka.server.authorizer.Authorizer
-
- AclState - Enum in org.apache.kafka.common.acl
-
Represents the state of an ACL.
- AclUpdateListener - Interface in org.apache.kafka.common.acl
-
Listeners which listens to Acl updates should implement this interface.
- 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
-
- all() - Method in class org.apache.kafka.clients.admin.AbortTransactionResult
-
- all() - Method in class org.apache.kafka.clients.admin.AlterBrokerHealthResult
-
Return a future which succeeds only if all the broker health state change changes succeed.
- 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
-
- 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
-
- 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
-
- all() - Method in class org.apache.kafka.clients.admin.DescribeTransactionsResult
-
- 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<String, Map<TopicPartition, OffsetAndMetadata>
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.
- ALLOWED_PATHS_CONFIG - Static variable in class org.apache.kafka.common.config.provider.DirectoryConfigProvider
-
- ALLOWED_PATHS_CONFIG - Static variable in class org.apache.kafka.common.config.provider.FileConfigProvider
-
- ALLOWED_PATHS_DOC - Static variable in class org.apache.kafka.common.config.provider.DirectoryConfigProvider
-
- ALLOWED_PATHS_DOC - Static variable in class org.apache.kafka.common.config.provider.FileConfigProvider
-
- ALLOWLIST_PATTERN_CONFIG - Static variable in class org.apache.kafka.common.config.provider.EnvVarConfigProvider
-
- ALLOWLIST_PATTERN_CONFIG_DOC - Static variable in class org.apache.kafka.common.config.provider.EnvVarConfigProvider
-
- 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
-
- alterBrokerHealth(AlterBrokerHealthSpec, AlterBrokerHealthOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- AlterBrokerHealthOptions - Class in org.apache.kafka.clients.admin
-
- AlterBrokerHealthOptions() - Constructor for class org.apache.kafka.clients.admin.AlterBrokerHealthOptions
-
- AlterBrokerHealthResult - Class in org.apache.kafka.clients.admin
-
The result of ConfluentAdmin#alterBrokerHealth(AlterBrokerHealthSpec, AlterBrokerHealthOptions)
.
- AlterBrokerHealthSpec - Class in org.apache.kafka.clients.admin
-
- AlterBrokerHealthSpec(Set<Integer>, ComponentHealthStatus, String) - Constructor for class org.apache.kafka.clients.admin.AlterBrokerHealthSpec
-
- AlterBrokerHealthSpec(Set<Integer>, BrokerComponent, ComponentHealthStatus, String) - Constructor for class org.apache.kafka.clients.admin.AlterBrokerHealthSpec
-
- AlterBrokerHealthSpec(Set<Integer>, BrokerComponent, ComponentHealthStatus, String, boolean) - Constructor for class org.apache.kafka.clients.admin.AlterBrokerHealthSpec
-
- 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
-
- AlterBrokerReplicaExclusionsResult.ExclusionsResult - Class in org.apache.kafka.clients.admin
-
- alterCell(int, CellState, AlterCellOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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.ForwardingAdmin
-
- alterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- AlterClientQuotasOptions - Class in org.apache.kafka.clients.admin
-
- AlterClientQuotasOptions() - Constructor for class org.apache.kafka.clients.admin.AlterClientQuotasOptions
-
- AlterClientQuotasResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in interface org.apache.kafka.clients.admin.Admin
-
- alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in class org.apache.kafka.clients.admin.ForwardingAdmin
-
Deprecated.
- alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
Deprecated.
- AlterConfigsOptions - Class in org.apache.kafka.clients.admin
-
- AlterConfigsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterConfigsOptions
-
- AlterConfigsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- AlterConsumerGroupOffsetsOptions - Class in org.apache.kafka.clients.admin
-
- AlterConsumerGroupOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions
-
- AlterConsumerGroupOffsetsResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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
-
- 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.ForwardingAdmin
-
- alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- AlterPartitionReassignmentsOptions - Class in org.apache.kafka.clients.admin
-
- AlterPartitionReassignmentsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions
-
- AlterPartitionReassignmentsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- alterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- AlterReplicaLogDirsOptions - Class in org.apache.kafka.clients.admin
-
- AlterReplicaLogDirsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions
-
- AlterReplicaLogDirsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- alterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- AlterUserScramCredentialsOptions - Class in org.apache.kafka.clients.admin
-
- AlterUserScramCredentialsOptions() - Constructor for class org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions
-
- AlterUserScramCredentialsResult - Class in org.apache.kafka.clients.admin
-
- 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.
- anyActionForResourcePattern(ResourcePattern) - Static method in class org.apache.kafka.server.authorizer.Action
-
- 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
-
- 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(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
-
- assignBrokersToCell(Collection<Integer>, int, boolean, AssignBrokersToCellOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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.
- assignPartitions(Map<String, List<PartitionInfo>>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.apache.kafka.clients.consumer.CooperativeStickyAssignor
-
- assignPartitions(Map<String, List<PartitionInfo>>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.apache.kafka.clients.consumer.RangeAssignor
-
Performs range assignment of the specified partitions for the consumers with the provided subscriptions.
- assignTenantsToCell(Collection<AssignTenantsToCellRequestData.TenantToCellAssignment>, AssignTenantsToCellOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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(Throwable, AuthenticationErrorInfo) - 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.
- 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
-
- authorizationIds() - Method in class org.apache.kafka.common.security.auth.ConfluentPrincipal
-
Returns list of ids which will be used to authorize to request.
- 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_INCLUDE_JMX_REPORTER_CONFIG - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig
-
Deprecated.
- AUTO_INCLUDE_JMX_REPORTER_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
-
Deprecated.
- AUTO_INCLUDE_JMX_REPORTER_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
-
Deprecated.
- AUTO_INCLUDE_JMX_REPORTER_DOC - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig
-
- 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
-
- AUTOMATIC_CONFIG_PROVIDERS_PROPERTY - Static variable in class org.apache.kafka.common.config.AbstractConfig
-
- available() - Method in enum org.apache.kafka.clients.admin.ClusterLinkDescription.LinkState
-
- 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.
- 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
-
- BalancerStatusDescription(BalancerStatus, Collection<Integer>, BalancerOperationError) - Constructor for class org.apache.kafka.clients.admin.BalancerStatusDescription
-
- 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
-
- 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
-
- Boolean() - Static method in class org.apache.kafka.common.serialization.Serdes
-
A serde for nullable Boolean
type.
- BooleanDeserializer - Class in org.apache.kafka.common.serialization
-
- BooleanDeserializer() - Constructor for class org.apache.kafka.common.serialization.BooleanDeserializer
-
- BooleanSerde() - Constructor for class org.apache.kafka.common.serialization.Serdes.BooleanSerde
-
- BooleanSerializer - Class in org.apache.kafka.common.serialization
-
- BooleanSerializer() - Constructor for class org.apache.kafka.common.serialization.BooleanSerializer
-
- 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
-
- 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
-
- brokerComponent() - Method in class org.apache.kafka.clients.admin.AlterBrokerHealthSpec
-
Which broker component's health is being modified.
- BrokerComponent - Enum in org.apache.kafka.clients.admin
-
- brokerComponent() - Method in class org.apache.kafka.clients.admin.BrokerHealthStatusResult
-
Indicates the broker component which was modified.
- brokerComponent() - Method in class org.apache.kafka.clients.admin.DegradedBrokerComponent
-
Indicates which component of the broker has been marked as degraded.
- 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
-
- BrokerHealthStatusResult - Class in org.apache.kafka.clients.admin
-
- brokerId() - Method in class org.apache.kafka.clients.admin.BrokerAdditionDescription
-
- brokerId() - Method in class org.apache.kafka.clients.admin.BrokerHealthStatusResult
-
The brokerId to change leadership priority on.
- 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.DegradedBroker
-
The brokerId whose health state we want to alter.
- 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.AlterBrokerHealthSpec
-
The list of brokers to alter broker health.
- 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
-
- 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.
- brokers() - Method in class org.apache.kafka.common.Cell
-
Return the set of brokers assigned to this cell
- 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.
- brokersList() - Method in class org.apache.kafka.common.Cell
-
Return the list of brokers assigned to this cell
- 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
always
rewinds
the position of the input buffer to zero for
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
-
- 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.
- Cell - Class in org.apache.kafka.common
-
Represents the contents of a cell, a collection of brokers.
- Cell(int, Set<Integer>, CellState, short, short) - Constructor for class org.apache.kafka.common.Cell
-
Represents the contents of a cell.
- cellId() - Method in class org.apache.kafka.common.Cell
-
The unique cell Id
- cellId() - Method in class org.apache.kafka.common.CellLoad
-
The unique cell Id
- cellId() - Method in class org.apache.kafka.common.Tenant
-
The cell ID
- CellLoad - Class in org.apache.kafka.common
-
Represents load information about a cell.
- CellLoad(int, double) - Constructor for class org.apache.kafka.common.CellLoad
-
Represents load information about a cell.
- CellNotFoundException - Exception in org.apache.kafka.common.errors
-
- CellNotFoundException(String) - Constructor for exception org.apache.kafka.common.errors.CellNotFoundException
-
- CellNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.CellNotFoundException
-
- CellState - Enum in org.apache.kafka.common
-
Represents the state of a cell, mostly indicating whether tenants can be moved in or out of a cell.
- 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
-
- 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.OAuthBearerLoginCallbackHandler
-
- CLIENT_ID_DOC - Static variable in class org.apache.kafka.common.security.oauthbearer.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.OAuthBearerLoginCallbackHandler
-
- CLIENT_SECRET_DOC - Static variable in class org.apache.kafka.common.security.oauthbearer.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.
- ClientQuotaClusterDescriber - Interface in org.apache.kafka.server.quota
-
- ClientQuotaClusterDescriber.Partition - Class in org.apache.kafka.server.quota
-
- 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
-
- 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.ForwardingAdmin
-
- 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
-
- close(Duration) - Method in interface org.apache.kafka.clients.producer.Producer
-
- 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.EnvVarConfigProvider
-
- 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 class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler
-
- close() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler
-
- 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.
- 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() - Method in class org.apache.kafka.server.quota.ZkClientQuotaClusterDescriber
-
- 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, ClusterLinkError, String, Node) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkDescription
-
Creates a cluster link description.
- ClusterLinkDescription(String, Uuid, String, String, Collection<String>, ClusterLinkDescription.LinkState, ClusterLinkDescription.LinkMode, ClusterLinkDescription.ConnectionMode, ClusterLinkError, String) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- ClusterLinkDescription(String, Uuid, String, String, Collection<String>, ClusterLinkDescription.LinkState, ClusterLinkDescription.LinkMode, ClusterLinkDescription.ConnectionMode, ClusterLinkError, String, int, String, int) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- ClusterLinkDescription(String, Uuid, String, String, Collection<String>, ClusterLinkDescription.LinkState, ClusterLinkDescription.LinkMode, ClusterLinkDescription.ConnectionMode) - Constructor for class org.apache.kafka.clients.admin.ClusterLinkDescription
-
Deprecated.
- 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
-
- clusterLinkError() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- clusterLinkError() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing
-
- ClusterLinkError - Enum in org.apache.kafka.common
-
Encodes a reason for why a link is in some sort of error state.
- clusterLinkError() - Method in exception org.apache.kafka.common.errors.InvalidClusterLinkException
-
- 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, ClusterLinkError, String) - 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
-
Deprecated.
- 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, ClusterLinkError, String, ClusterLinkDescription.LinkState) - 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
-
- 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.acl.AclState
-
Return the code of this operation.
- code() - Method in enum org.apache.kafka.common.CellState
-
- code() - Method in enum org.apache.kafka.common.MirrorTopicError
-
- code() - Method in enum org.apache.kafka.common.PartitionPlacementStrategy
-
- 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
-
- 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
-
- 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
-
- committed(TopicPartition, Duration) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer
-
- 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
-
- commitTransactionException - Variable in class org.apache.kafka.clients.producer.MockProducer
-
- CommonExtensionsValidatorCallback - Class in org.apache.kafka.common.security.oauthbearer
-
- CommonExtensionsValidatorCallback(SaslExtensions, ClientContext) - Constructor for class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
- CommonExtensionsValidatorCallback(SaslExtensions) - Constructor for class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
- 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
-
- completedFuture(U) - Static method in class org.apache.kafka.common.KafkaFuture
-
Returns a new KafkaFuture that is already completed with the given value.
- completeNext() - Method in class org.apache.kafka.clients.producer.MockProducer
-
Complete the earliest uncompleted call successfully.
- componentHealthStatus() - Method in class org.apache.kafka.clients.admin.AlterBrokerHealthSpec
-
Whether to mark a broker component's health as degraded (0) or healthy (1).
- componentHealthStatus() - Method in class org.apache.kafka.clients.admin.BrokerHealthStatusResult
-
Indicates the broker component's new health status.
- ComponentHealthStatus - Enum in org.apache.kafka.clients.admin
-
- 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
-
- 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
-
- ConfigData - Class in org.apache.kafka.common.config
-
- 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
-
- 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
- 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.EnvVarConfigProvider
-
- 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.OAuthBearerLoginCallbackHandler
-
- configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class org.apache.kafka.common.security.oauthbearer.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.
- 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
-
- ConfluentPrincipal(String, String, String, Optional<String>, boolean, Set<String>) - Constructor for class org.apache.kafka.common.security.auth.ConfluentPrincipal
-
- ConfluentPrincipal(String, String, String, Optional<String>, boolean, Set<String>, List<String>) - Constructor for class org.apache.kafka.common.security.auth.ConfluentPrincipal
-
authorizationIds: Contains list of ids used in authorization.
- 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
-
- 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
-
- 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.
- consumerOutboundKBps() - Method in class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources
-
Cluster's consumer outbound traffic in KB/s.
- 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
-
- ConsumerRecord(String, int, long, long, TimestampType, Long, int, int, K, V, Headers) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord
-
- ConsumerRecord(String, int, long, long, TimestampType, Long, int, int, K, V, Headers, Optional<Integer>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord
-
- 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.
- context() - Method in class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
- context() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback
-
- 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.
- createAcls(Collection<AclBinding>) - Method in interface org.apache.kafka.clients.admin.Admin
-
- 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.ForwardingAdmin
-
- 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
-
- CreateAclsOptions() - Constructor for class org.apache.kafka.clients.admin.CreateAclsOptions
-
- CreateAclsResult - Class in org.apache.kafka.clients.admin
-
- createCell(int, CellState, CreateCellOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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
-
- CreateClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.CreateClusterLinksOptions
-
- CreateClusterLinksResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- createDelegationToken(CreateDelegationTokenOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- CreateDelegationTokenOptions - Class in org.apache.kafka.clients.admin
-
- CreateDelegationTokenOptions() - Constructor for class org.apache.kafka.clients.admin.CreateDelegationTokenOptions
-
- CreateDelegationTokenResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- createPartitions(Map<String, NewPartitions>, CreatePartitionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- CreatePartitionsOptions - Class in org.apache.kafka.clients.admin
-
- CreatePartitionsOptions() - Constructor for class org.apache.kafka.clients.admin.CreatePartitionsOptions
-
- CreatePartitionsResult - Class in org.apache.kafka.clients.admin
-
- createServerSslEngine(String, int) - Method in interface org.apache.kafka.common.security.auth.SslEngineFactory
-
Creates a new SSLEngine
object to be used by the server.
- 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.ForwardingAdmin
-
- createTopics(Collection<NewTopic>, CreateTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- CreateTopicsOptions - Class in org.apache.kafka.clients.admin
-
- CreateTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.CreateTopicsOptions
-
- CreateTopicsResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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
-
- 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.
- data(String, String) - Method in class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
Add any extra information apart from extensions.
- data() - Method in class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
- 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_CLIENT_RACK - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
-
- 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_FETCH_MAX_WAIT_MS - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
-
- DEFAULT_FETCH_MIN_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_MAX_POLL_RECORDS - 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.
- DegradedBroker - Class in org.apache.kafka.clients.admin
-
- DegradedBroker(int, Set<DegradedBrokerComponent>) - Constructor for class org.apache.kafka.clients.admin.DegradedBroker
-
- DegradedBrokerComponent - Class in org.apache.kafka.clients.admin
-
- DegradedBrokerComponent(String, byte) - Constructor for class org.apache.kafka.clients.admin.DegradedBrokerComponent
-
- degradedBrokerComponents() - Method in class org.apache.kafka.clients.admin.DegradedBroker
-
The set of degraded broker components.
- 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
-
- 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.ForwardingAdmin
-
- 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>, AclState) - Method in interface org.apache.kafka.server.authorizer.Authorizer
-
- DeleteAclsOptions - Class in org.apache.kafka.clients.admin
-
- DeleteAclsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteAclsOptions
-
- DeleteAclsResult - Class in org.apache.kafka.clients.admin
-
- 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.
- deleteCell(int, DeleteCellOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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
-
- DeleteClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteClusterLinksOptions
-
- DeleteClusterLinksResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- deleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DeleteConsumerGroupOffsetsOptions - Class in org.apache.kafka.clients.admin
-
- DeleteConsumerGroupOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsOptions
-
- DeleteConsumerGroupOffsetsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- deleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DeleteConsumerGroupsOptions - Class in org.apache.kafka.clients.admin
-
- DeleteConsumerGroupsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions
-
- DeleteConsumerGroupsResult - Class in org.apache.kafka.clients.admin
-
- 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.
- deleteMetadata() - Method in class org.apache.kafka.clients.admin.DeleteClusterLinksOptions
-
Whether to delete the metadata after marking it for deletion.
- deleteMetadata(boolean) - Method in class org.apache.kafka.clients.admin.DeleteClusterLinksOptions
-
- 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.ForwardingAdmin
-
- deleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DeleteRecordsOptions - Class in org.apache.kafka.clients.admin
-
- DeleteRecordsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteRecordsOptions
-
- DeleteRecordsResult - Class in org.apache.kafka.clients.admin
-
- DeleteRecordsResult(Map<TopicPartition, KafkaFuture<DeletedRecords>>) - Constructor for class org.apache.kafka.clients.admin.DeleteRecordsResult
-
- deleteTenants(Collection<String>, DeleteTenantsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- deleteTopics(Collection<String>) - Method in interface org.apache.kafka.clients.admin.Admin
-
- deleteTopics(Collection<String>, DeleteTopicsOptions) - Method in interface org.apache.kafka.clients.admin.Admin
-
- deleteTopics(TopicCollection) - Method in interface org.apache.kafka.clients.admin.Admin
-
- 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.ForwardingAdmin
-
- deleteTopics(TopicCollection, DeleteTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DeleteTopicsOptions - Class in org.apache.kafka.clients.admin
-
- DeleteTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.DeleteTopicsOptions
-
- DeleteTopicsResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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.ForwardingAdmin
-
- describeAcls(AclBindingFilter, DescribeAclsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeAclsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeAclsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeAclsOptions
-
- DescribeAclsResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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
-
- describeBrokerHealth(DescribeBrokerHealthOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeBrokerHealthOptions - Class in org.apache.kafka.clients.admin
-
- DescribeBrokerHealthOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeBrokerHealthOptions
-
- DescribeBrokerHealthResult - Class in org.apache.kafka.clients.admin
-
The result of ConfluentAdmin#describeBrokerHealth(DescribeBrokerHealthOptions)
.
- 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
-
- 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
-
- 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.
- describeCellLoad(Collection<Integer>, DescribeCellLoadOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- describeCellLoad(Collection<Integer>) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- describeCells(Collection<Integer>, DescribeCellsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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.ForwardingAdmin
-
- describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeClientQuotasOptions - Class in org.apache.kafka.clients.admin
-
- DescribeClientQuotasOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeClientQuotasOptions
-
- DescribeClientQuotasResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- 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
-
- DescribeClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeClusterLinksOptions
-
- DescribeClusterLinksResult - Class in org.apache.kafka.clients.admin
-
- DescribeClusterLinksResult(KafkaFuture<Collection<ClusterLinkDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeClusterLinksResult
-
- DescribeClusterOptions - Class in org.apache.kafka.clients.admin
-
- DescribeClusterOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeClusterOptions
-
- DescribeClusterResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeConfigsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeConfigsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeConfigsOptions
-
- DescribeConfigsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeConsumerGroupsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeConsumerGroupsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions
-
- DescribeConsumerGroupsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeDelegationToken(DescribeDelegationTokenOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeDelegationTokenOptions - Class in org.apache.kafka.clients.admin
-
- DescribeDelegationTokenOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeDelegationTokenOptions
-
- DescribeDelegationTokenResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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.ForwardingAdmin
-
- describeFeatures(DescribeFeaturesOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeFeaturesOptions - Class in org.apache.kafka.clients.admin
-
- DescribeFeaturesOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeFeaturesOptions
-
- DescribeFeaturesResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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.ForwardingAdmin
-
- describeLogDirs(Collection<Integer>, DescribeLogDirsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeLogDirsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeLogDirsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeLogDirsOptions
-
- DescribeLogDirsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeMetadataQuorum(DescribeMetadataQuorumOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeMetadataQuorumOptions - Class in org.apache.kafka.clients.admin
-
- DescribeMetadataQuorumOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeMetadataQuorumOptions
-
- DescribeMetadataQuorumResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- DescribeMirrorsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeMirrorsOptions
-
- DescribeMirrorsResult - Class in org.apache.kafka.clients.admin
-
- DescribeMirrorsResult(Map<String, KafkaFuture<MirrorTopicDescription>>) - Constructor for class org.apache.kafka.clients.admin.DescribeMirrorsResult
-
- describeNetwork(String, String, Collection<String>, Collection<String>, DescribeNetworkOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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.ForwardingAdmin
-
- describeProducers(Collection<TopicPartition>, DescribeProducersOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeProducersOptions - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeReplicaLogDirsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeReplicaLogDirsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions
-
- DescribeReplicaLogDirsResult - Class in org.apache.kafka.clients.admin
-
- DescribeReplicaLogDirsResult.ReplicaLogDirInfo - Class in org.apache.kafka.clients.admin
-
- describeTenants(Collection<String>, DescribeTenantsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- 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
-
- 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.ForwardingAdmin
-
- describeTopics(TopicCollection, DescribeTopicsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeTopicsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeTopicsOptions
-
- DescribeTopicsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeTransactions(Collection<String>, DescribeTransactionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeTransactionsOptions - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- describeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- DescribeUserScramCredentialsOptions - Class in org.apache.kafka.clients.admin
-
- DescribeUserScramCredentialsOptions() - Constructor for class org.apache.kafka.clients.admin.DescribeUserScramCredentialsOptions
-
- DescribeUserScramCredentialsResult - Class in org.apache.kafka.clients.admin
-
- 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(String, byte[]) - Method in class org.apache.kafka.common.serialization.BooleanDeserializer
-
- 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
-
- 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
-
- 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
-
- 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.ForwardingAdmin
-
- electLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ElectLeadersOptions - Class in org.apache.kafka.clients.admin
-
- ElectLeadersOptions() - Constructor for class org.apache.kafka.clients.admin.ElectLeadersOptions
-
- ElectLeadersResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- EnvVarConfigProvider - Class in org.apache.kafka.common.config.provider
-
- EnvVarConfigProvider() - Constructor for class org.apache.kafka.common.config.provider.EnvVarConfigProvider
-
- EnvVarConfigProvider(Map<String, String>) - Constructor for class org.apache.kafka.common.config.provider.EnvVarConfigProvider
-
- 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.AlterBrokerHealthSpec
-
- 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.DegradedBroker
-
- equals(Object) - Method in class org.apache.kafka.clients.admin.DegradedBrokerComponent
-
- 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.Cell
-
- equals(Object) - Method in class org.apache.kafka.common.CellLoad
-
- 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
-
- 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.Tenant
-
- 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
-
- equals(Object) - Method in class org.apache.kafka.server.quota.ClientQuotaClusterDescriber.Partition
-
- 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.CommonExtensionsValidatorCallback
-
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
-
- error(String, String, String) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback
-
- 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
-
- errorDescription() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback
-
- 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.CommonExtensionsValidatorCallback
-
- errorMessage(String) - Method in class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
- 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
-
- errorOpt() - Method in class org.apache.kafka.clients.admin.ExclusionOpResult
-
- errorOrDefault(MirrorTopicError, boolean) - Static method in enum org.apache.kafka.common.MirrorTopicError
-
- 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
-
- errorStatus() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback
-
- errorUri() - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback
-
- 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
-
- EvenClusterLoadPlanBrokerRelatedStats - Class in org.apache.kafka.clients.admin
-
- EvenClusterLoadPlanBrokerRelatedStats(List<Integer>, List<Integer>, List<Integer>, List<Integer>) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerRelatedStats
-
- 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
-
- EvenClusterLoadPlanClusterRelatedStats - Class in org.apache.kafka.clients.admin
-
- EvenClusterLoadPlanClusterRelatedStats(int, double, List<String>, int, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanClusterRelatedStats
-
- EvenClusterLoadPlanDetailedClusterBalanceStats - Class in org.apache.kafka.clients.admin
-
- EvenClusterLoadPlanDetailedClusterBalanceStats(double, double, List<EvenClusterLoadPlanBrokerStats>, List<EvenClusterLoadPlanBrokerStats>) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanDetailedClusterBalanceStats
-
- EvenClusterLoadPlanGoalRelatedStats - Class in org.apache.kafka.clients.admin
-
- EvenClusterLoadPlanGoalRelatedStats(List<String>, List<EvenClusterLoadPlanGoalStats>, List<String>, List<String>) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalRelatedStats
-
- 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
-
- 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
-
- 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
-
- 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
-
- EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, double, int, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources
-
- EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, double, double, int, int, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources
-
- EvenClusterLoadPlanReplicaMovementStats - Class in org.apache.kafka.clients.admin
-
- EvenClusterLoadPlanReplicaMovementStats(int, double, int) - Constructor for class org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats
-
- 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
-
- 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
-
- 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
-
- 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.ForwardingAdmin
-
- expireDelegationToken(byte[], ExpireDelegationTokenOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ExpireDelegationTokenOptions - Class in org.apache.kafka.clients.admin
-
- ExpireDelegationTokenOptions() - Constructor for class org.apache.kafka.clients.admin.ExpireDelegationTokenOptions
-
- ExpireDelegationTokenResult - Class in org.apache.kafka.clients.admin
-
- 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.
- 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
-
- FencedMemberEpochException - Exception in org.apache.kafka.common.errors
-
- FencedMemberEpochException(String) - Constructor for exception org.apache.kafka.common.errors.FencedMemberEpochException
-
- 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.ForwardingAdmin
-
- fenceProducers(Collection<String>, FenceProducersOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- FenceProducersOptions - Class in org.apache.kafka.clients.admin
-
- FenceProducersOptions() - Constructor for class org.apache.kafka.clients.admin.FenceProducersOptions
-
- FenceProducersResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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
-
- 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.AlterBrokerHealthSpec
-
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.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.
- forCode(short, boolean) - Static method in enum org.apache.kafka.common.MirrorTopicError
-
- 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.BrokerComponent
-
- forId(byte) - Static method in enum org.apache.kafka.clients.admin.ComponentHealthStatus
-
- 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
- forString(String) - Static method in enum org.apache.kafka.clients.admin.BrokerComponent
-
- forString(String) - Static method in enum org.apache.kafka.clients.admin.ComponentHealthStatus
-
- 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
- ForwardingAdmin - Class in org.apache.kafka.clients.admin
-
ForwardingAdmin
is the default value of forwarding.admin.class
in MirrorMaker.
- ForwardingAdmin(Map<String, Object>) - Constructor for class org.apache.kafka.clients.admin.ForwardingAdmin
-
- 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.acl.AclState
-
Returns the AclState with the provided code.
- fromCode(byte) - Static method in enum org.apache.kafka.common.resource.PatternType
-
- 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
-
- fromShort(short) - Static method in enum org.apache.kafka.common.ClusterLinkError
-
- 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
-
- 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.DescribeBrokerHealthResult
-
Returns a future collection of degraded brokers and their reasons for being degraded.
- future() - Method in class org.apache.kafka.clients.admin.DescribeLeadershipPriorityResult
-
Returns a future collection of demoted brokers and their reasons for demotion.
- 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
-
- generationId() - Method in class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Subscription
-
- 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 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.EnvVarConfigProvider
-
- get(String, Set<String>) - Method in class org.apache.kafka.common.config.provider.EnvVarConfigProvider
-
- 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.
- getAssignorInstances(List<String>, Map<String, Object>) - Static method in interface org.apache.kafka.clients.consumer.ConsumerPartitionAssignor
-
- 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.
- 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
-
- getGroups() - Method in class org.apache.kafka.common.security.auth.ConfluentPrincipal
-
Returns the principal groups if provided during authentication.
- getImplicitBrokerCellId(int, int) - Static method in class org.apache.kafka.common.Cell
-
Computes the implicit cell-id based on the cellSize
- getInnerSerializer() - Method in class org.apache.kafka.common.serialization.ListSerializer
-
- getInt(String) - Method in class org.apache.kafka.common.config.AbstractConfig
-
- 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
-
- 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.
- getPassword(String) - Method in class org.apache.kafka.common.config.AbstractConfig
-
- 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
-
- getString(String) - Method in class org.apache.kafka.common.config.AbstractConfig
-
- 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
-
- getValue() - Method in enum org.apache.kafka.common.ClusterLinkError
-
- 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
- GROUP_TYPE - Static variable in class org.apache.kafka.common.security.auth.ConfluentPrincipal
-
- 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
-
- 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.BrokerComponent
-
- id() - Method in enum org.apache.kafka.clients.admin.BrokerLeadershipPriorityResult.LeadershipPriorityEnum
-
- id() - Method in enum org.apache.kafka.clients.admin.ComponentHealthStatus
-
- 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() - 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
- id() - Method in class org.apache.kafka.server.quota.ClientQuotaClusterDescriber.Partition
-
- 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.CommonExtensionsValidatorCallback
-
- 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.ForwardingAdmin
-
- 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(AccessTokenRetriever, AccessTokenValidator) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler
-
- init(CloseableVerificationKeyResolver, AccessTokenValidator) - Method in class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler
-
- 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
-
- 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
-
- innerDeserializer() - Method in class org.apache.kafka.common.serialization.ListDeserializer
-
- inputExtensions() - Method in class org.apache.kafka.common.security.oauthbearer.CommonExtensionsValidatorCallback
-
- 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.
- InsufficientDataForCellLoadComputationException - Exception in org.apache.kafka.common.errors
-
- InsufficientDataForCellLoadComputationException(String) - Constructor for exception org.apache.kafka.common.errors.InsufficientDataForCellLoadComputationException
-
- InsufficientDataForCellLoadComputationException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InsufficientDataForCellLoadComputationException
-
- 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(ClusterLinkError, String, String) - Constructor for exception org.apache.kafka.common.errors.InvalidClusterLinkException
-
- InvalidClusterLinkException(ClusterLinkError, 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.CommonExtensionsValidatorCallback
-
- 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
-
- isActive() - Method in enum org.apache.kafka.common.acl.AclState
-
Returns true if the ACL is an active ACL.
- 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.
- 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.
- isDeleted() - Method in enum org.apache.kafka.common.acl.AclState
-
Returns true if the ACL is deleted and is in inactive state.
- isDone() - Method in class org.apache.kafka.common.KafkaFuture
-
Returns true if completed in any fashion: normally, exceptionally, or via cancellation.
- isDowngradeAllowed() - Method in enum org.apache.kafka.clients.admin.BrokerComponent
-
Returns whether downgrading from this component to UNSPECIFIED
is supported.
- 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
-
- 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.acl.AclState
-
Returns true if the ACL is in Unknown State
- 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
-
- isValid(short) - Method in enum org.apache.kafka.clients.admin.BrokerComponent
-
- 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
-
- 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
- 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.
- leader() - Method in class org.apache.kafka.server.quota.ClientQuotaClusterDescriber.Partition
-
- 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
- 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
- linkCoordinatorHost() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- linkCoordinatorId() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- linkCoordinatorPort() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- linkErrorMessage() - Method in class org.apache.kafka.clients.admin.ClusterLinkDescription
-
- linkErrorMessage() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing
-
- linkErrorMessage() - Method in exception org.apache.kafka.common.errors.InvalidClusterLinkException
-
- linkId() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing
-
Deprecated.
- linkId() - Method in class org.apache.kafka.clients.admin.MirrorTopicDescription
-
Deprecated.
- linkId() - Method in class org.apache.kafka.clients.admin.NewClusterLink
-
The link id for a source or bi-directional cluster link.
- 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.DescribeMirrorsOptions
-
- linkNames(Collection<String>) - Method in class org.apache.kafka.clients.admin.DescribeMirrorsOptions
-
- 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
-
- linkState() - Method in class org.apache.kafka.clients.admin.ClusterLinkListing
-
- 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
-
- ListClusterLinksOptions() - Constructor for class org.apache.kafka.clients.admin.ListClusterLinksOptions
-
- ListClusterLinksResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- listConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ListConsumerGroupOffsetsOptions - Class in org.apache.kafka.clients.admin
-
- ListConsumerGroupOffsetsOptions() - Constructor for class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions
-
- ListConsumerGroupOffsetsResult - Class in org.apache.kafka.clients.admin
-
- ListConsumerGroupOffsetsSpec - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- listConsumerGroups(ListConsumerGroupsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ListConsumerGroupsOptions - Class in org.apache.kafka.clients.admin
-
- ListConsumerGroupsOptions() - Constructor for class org.apache.kafka.clients.admin.ListConsumerGroupsOptions
-
- ListConsumerGroupsResult - Class in org.apache.kafka.clients.admin
-
- 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
-
- ListMirrorsOptions() - Constructor for class org.apache.kafka.clients.admin.ListMirrorsOptions
-
- ListMirrorsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- listOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ListOffsetsOptions - Class in org.apache.kafka.clients.admin
-
- 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
-
- 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
-
- listPartitionReassignments(Set<TopicPartition>) - Method in interface org.apache.kafka.clients.admin.Admin
-
- 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.ForwardingAdmin
-
- listPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ListPartitionReassignmentsOptions - Class in org.apache.kafka.clients.admin
-
- ListPartitionReassignmentsOptions() - Constructor for class org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions
-
- ListPartitionReassignmentsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- 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
-
- ListTopicsOptions() - Constructor for class org.apache.kafka.clients.admin.ListTopicsOptions
-
- ListTopicsResult - Class in org.apache.kafka.clients.admin
-
- 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.ForwardingAdmin
-
- listTransactions(ListTransactionsOptions) - Method in class org.apache.kafka.clients.admin.KafkaAdminClient
-
- ListTransactionsOptions - Class in org.apache.kafka.clients.admin
-
- ListTransactionsOptions() - Constructor for class org.apache.kafka.clients.admin.ListTransactionsOptions
-
- ListTransactionsResult - Class in org.apache.kafka.clients.admin
-
- LKC_ID - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig
-
- LKC_ID - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
-
- LKC_ID - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
-
- LKC_ID_DOC - Static variable in class org.apache.kafka.clients.admin.AdminClientConfig
-
- LKC_ID_DOC - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
-
- LKC_ID_DOC - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
-
- load() - Method in class org.apache.kafka.common.CellLoad
-
Return the composite load of this cell (incorporating broker load, network limit, storage and CPU limits etc.)
- 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
-
- 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
-
- 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.kaf