JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Hierarchy For All Packages
Package Hierarchies:
org.apache.kafka.clients.admin
,
org.apache.kafka.clients.consumer
,
org.apache.kafka.clients.producer
,
org.apache.kafka.common
,
org.apache.kafka.common.acl
,
org.apache.kafka.common.annotation
,
org.apache.kafka.common.config
,
org.apache.kafka.common.config.provider
,
org.apache.kafka.common.errors
,
org.apache.kafka.common.header
,
org.apache.kafka.common.metrics
,
org.apache.kafka.common.metrics.stats
,
org.apache.kafka.common.quota
,
org.apache.kafka.common.resource
,
org.apache.kafka.common.security.auth
,
org.apache.kafka.common.security.oauthbearer
,
org.apache.kafka.common.security.oauthbearer.secured
,
org.apache.kafka.common.security.plain
,
org.apache.kafka.common.security.scram
,
org.apache.kafka.common.security.token.delegation
,
org.apache.kafka.common.serialization
,
org.apache.kafka.server.authorizer
,
org.apache.kafka.server.policy
,
org.apache.kafka.server.quota
,
org.apache.kafka.server.telemetry
Class Hierarchy
java.lang.
Object
org.apache.kafka.clients.admin.
AbortTransactionResult
org.apache.kafka.clients.admin.
AbortTransactionSpec
org.apache.kafka.common.config.
AbstractConfig
org.apache.kafka.clients.admin.
AdminClientConfig
org.apache.kafka.clients.consumer.
ConsumerConfig
org.apache.kafka.clients.producer.
ProducerConfig
org.apache.kafka.clients.admin.
AbstractOptions
<T>
org.apache.kafka.clients.admin.
AbortTransactionOptions
org.apache.kafka.clients.admin.
AlterBrokerHealthOptions
org.apache.kafka.clients.admin.
AlterBrokerReplicaExclusionsOptions
org.apache.kafka.clients.admin.
AlterClientQuotasOptions
org.apache.kafka.clients.admin.
AlterConfigsOptions
org.apache.kafka.clients.admin.
AlterConsumerGroupOffsetsOptions
org.apache.kafka.clients.admin.
AlterLeadershipPriorityOptions
org.apache.kafka.clients.admin.
AlterMirrorsOptions
org.apache.kafka.clients.admin.
AlterPartitionReassignmentsOptions
org.apache.kafka.clients.admin.
AlterReplicaLogDirsOptions
org.apache.kafka.clients.admin.
AlterUserScramCredentialsOptions
org.apache.kafka.clients.admin.
ComputeEvenClusterLoadPlanOptions
org.apache.kafka.clients.admin.
CreateAclsOptions
org.apache.kafka.clients.admin.
CreateClusterLinksOptions
org.apache.kafka.clients.admin.
CreateDelegationTokenOptions
org.apache.kafka.clients.admin.
CreatePartitionsOptions
org.apache.kafka.clients.admin.
CreateTopicsOptions
org.apache.kafka.clients.admin.
DeleteAclsOptions
org.apache.kafka.clients.admin.
DeleteClusterLinksOptions
org.apache.kafka.clients.admin.
DeleteConsumerGroupOffsetsOptions
org.apache.kafka.clients.admin.
DeleteConsumerGroupsOptions
org.apache.kafka.clients.admin.
DeleteRecordsOptions
org.apache.kafka.clients.admin.
DeleteTopicsOptions
org.apache.kafka.clients.admin.
DescribeAclsOptions
org.apache.kafka.clients.admin.
DescribeBalancerStatusOptions
org.apache.kafka.clients.admin.
DescribeBrokerAdditionsOptions
org.apache.kafka.clients.admin.
DescribeBrokerHealthOptions
org.apache.kafka.clients.admin.
DescribeBrokerRemovalsOptions
org.apache.kafka.clients.admin.
DescribeBrokerReplicaExclusionsOptions
org.apache.kafka.clients.admin.
DescribeClientQuotasOptions
org.apache.kafka.clients.admin.
DescribeClusterLinksOptions
org.apache.kafka.clients.admin.
DescribeClusterOptions
org.apache.kafka.clients.admin.
DescribeConfigsOptions
org.apache.kafka.clients.admin.
DescribeConsumerGroupsOptions
org.apache.kafka.clients.admin.
DescribeDelegationTokenOptions
org.apache.kafka.clients.admin.
DescribeEvenClusterLoadStatusOptions
org.apache.kafka.clients.admin.
DescribeFeaturesOptions
org.apache.kafka.clients.admin.
DescribeLeadershipPriorityOptions
org.apache.kafka.clients.admin.
DescribeLogDirsOptions
org.apache.kafka.clients.admin.
DescribeMetadataQuorumOptions
org.apache.kafka.clients.admin.
DescribeMirrorsOptions
org.apache.kafka.clients.admin.
DescribeProducersOptions
org.apache.kafka.clients.admin.
DescribeReplicaLogDirsOptions
org.apache.kafka.clients.admin.
DescribeTopicsOptions
org.apache.kafka.clients.admin.
DescribeTransactionsOptions
org.apache.kafka.clients.admin.
DescribeUserScramCredentialsOptions
org.apache.kafka.clients.admin.
ElectLeadersOptions
org.apache.kafka.clients.admin.
ExpireDelegationTokenOptions
org.apache.kafka.clients.admin.
FenceProducersOptions
org.apache.kafka.clients.admin.
ListClientMetricsResourcesOptions
org.apache.kafka.clients.admin.
ListClusterLinksOptions
org.apache.kafka.clients.admin.
ListConsumerGroupOffsetsOptions
org.apache.kafka.clients.admin.
ListConsumerGroupsOptions
org.apache.kafka.clients.admin.
ListMirrorsOptions
org.apache.kafka.clients.admin.
ListOffsetsOptions
org.apache.kafka.clients.admin.
ListPartitionReassignmentsOptions
org.apache.kafka.clients.admin.
ListTopicsOptions
org.apache.kafka.clients.admin.
ListTransactionsOptions
org.apache.kafka.clients.admin.
RemoveBrokersOptions
org.apache.kafka.clients.admin.
RemoveMembersFromConsumerGroupOptions
org.apache.kafka.clients.admin.
RenewDelegationTokenOptions
org.apache.kafka.clients.admin.
ReplicaStatusOptions
org.apache.kafka.clients.admin.
TriggerEvenClusterLoadOptions
org.apache.kafka.clients.admin.
UnregisterBrokerOptions
org.apache.kafka.clients.admin.
UpdateFeaturesOptions
org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor (implements org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor
)
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor
org.apache.kafka.clients.consumer.
CooperativeStickyAssignor
org.apache.kafka.clients.consumer.
StickyAssignor
org.apache.kafka.clients.consumer.
RangeAssignor
org.apache.kafka.clients.consumer.
RoundRobinAssignor
org.apache.kafka.common.acl.
AccessControlEntry
org.apache.kafka.common.acl.
AccessControlEntryFilter
org.apache.kafka.common.acl.
AclBinding
org.apache.kafka.common.acl.
AclBindingFilter
org.apache.kafka.server.authorizer.
AclCreateResult
org.apache.kafka.server.authorizer.
AclDeleteResult
org.apache.kafka.server.authorizer.
AclDeleteResult.AclBindingDeleteResult
org.apache.kafka.server.authorizer.
Action
org.apache.kafka.clients.admin.
AdminClient
(implements org.apache.kafka.clients.admin.
Admin
)
org.apache.kafka.clients.admin.
KafkaAdminClient
(implements io.confluent.kafka.clients.CloudAdmin)
org.apache.kafka.clients.admin.
AlterBrokerHealthResult
org.apache.kafka.clients.admin.
AlterBrokerHealthSpec
org.apache.kafka.clients.admin.
AlterBrokerReplicaExclusionsResult
org.apache.kafka.clients.admin.
AlterBrokerReplicaExclusionsResult.ExclusionsResult
org.apache.kafka.clients.admin.
AlterClientQuotasResult
org.apache.kafka.clients.admin.
AlterConfigOp
org.apache.kafka.server.policy.
AlterConfigPolicy.RequestMetadata
org.apache.kafka.clients.admin.
AlterConfigsResult
org.apache.kafka.clients.admin.
AlterConsumerGroupOffsetsResult
org.apache.kafka.clients.admin.
AlterLeadershipPriorityResult
org.apache.kafka.clients.admin.
AlterLeadershipPrioritySpec
org.apache.kafka.clients.admin.
AlterMirrorsResult
org.apache.kafka.clients.admin.
AlterPartitionReassignmentsResult
org.apache.kafka.clients.admin.
AlterReplicaLogDirsResult
org.apache.kafka.clients.admin.
AlterUserScramCredentialsResult
org.apache.kafka.server.authorizer.
AuthorizerConfig
org.apache.kafka.clients.admin.
BalancerOperationError
org.apache.kafka.clients.admin.
BrokerRemovalError
org.apache.kafka.clients.admin.
BalancerStatusDescription
org.apache.kafka.common.serialization.
BooleanDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
BooleanSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.clients.admin.
BrokerAdditionDescription
org.apache.kafka.clients.admin.
BrokerHealthStatusResult
org.apache.kafka.clients.admin.
BrokerLeadershipPriorityResult
org.apache.kafka.clients.admin.
BrokerRemovalDescription
org.apache.kafka.common.serialization.
ByteArrayDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
ByteArraySerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.common.serialization.
ByteBufferDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
ByteBufferSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.common.serialization.
BytesDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
BytesSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.common.
Cell
org.apache.kafka.common.
CellLoad
org.apache.kafka.clients.admin.
ClientMetricsResourceListing
org.apache.kafka.common.quota.
ClientQuotaAlteration
org.apache.kafka.common.quota.
ClientQuotaAlteration.Op
org.apache.kafka.server.quota.
ClientQuotaClusterDescriber.Partition
org.apache.kafka.common.quota.
ClientQuotaEntity
org.apache.kafka.common.quota.
ClientQuotaFilter
org.apache.kafka.common.quota.
ClientQuotaFilterComponent
org.apache.kafka.server.quota.
ClientQuotaMetricsUtil
org.apache.kafka.common.
Cluster
org.apache.kafka.clients.admin.
ClusterLinkDescription
org.apache.kafka.clients.admin.
ClusterLinkDescription.Builder
org.apache.kafka.clients.admin.
ClusterLinkListing
org.apache.kafka.clients.admin.
ClusterLinkTaskDescription
org.apache.kafka.clients.admin.
ClusterLinkTaskError
org.apache.kafka.common.
ClusterResource
org.apache.kafka.common.security.oauthbearer.
CommonExtensionsValidatorCallback
(implements javax.security.auth.callback.
Callback
, org.apache.kafka.common.security.oauthbearer.
Contextable
)
org.apache.kafka.common.security.oauthbearer.
OAuthBearerExtensionsValidatorCallback
org.apache.kafka.common.security.oauthbearer.
PreTokenValidationExtensionsValidatorCallback
org.apache.kafka.common.metrics.
CompoundStat.NamedMeasurable
org.apache.kafka.clients.admin.
ComputeEvenClusterLoadPlanResult
org.apache.kafka.clients.admin.
Config
org.apache.kafka.common.config.
Config
org.apache.kafka.common.config.
ConfigData
org.apache.kafka.common.config.
ConfigDef
org.apache.kafka.common.config.
ConfigDef.CaseInsensitiveValidString
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.CompositeValidator
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.ConcreteSubClassValidator
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.ConfigKey
org.apache.kafka.common.config.
ConfigDef.InstantiableClassValidator
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.LambdaValidator
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.ListSize
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.NonEmptyString
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.NonEmptyStringWithoutControlChars
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.NonNullValidator
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.Range
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.ValidList
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.common.config.
ConfigDef.ValidString
(implements org.apache.kafka.common.config.
ConfigDef.Validator
)
org.apache.kafka.clients.admin.
ConfigEntry
org.apache.kafka.clients.admin.
ConfigEntry.ConfigSynonym
org.apache.kafka.common.config.
ConfigResource
org.apache.kafka.common.config.
ConfigTransformer
org.apache.kafka.common.config.
ConfigTransformerResult
org.apache.kafka.common.config.
ConfigValue
org.apache.kafka.common.config.
ConfluentTopicConfig
org.apache.kafka.clients.admin.
ConsumerGroupDescription
org.apache.kafka.clients.admin.
ConsumerGroupListing
org.apache.kafka.clients.consumer.
ConsumerGroupMetadata
org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor.Assignment
org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor.GroupAssignment
org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor.GroupSubscription
org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor.Subscription
org.apache.kafka.clients.consumer.
ConsumerRecord
<K,V>
org.apache.kafka.clients.consumer.
ConsumerRecords
<K,V> (implements java.lang.
Iterable
<T>)
org.apache.kafka.clients.admin.
CreateAclsResult
org.apache.kafka.clients.admin.
CreateClusterLinksResult
org.apache.kafka.clients.admin.
CreateDelegationTokenResult
org.apache.kafka.clients.admin.
CreatePartitionsResult
org.apache.kafka.server.policy.
CreateTopicPolicy.RequestMetadata
org.apache.kafka.clients.admin.
CreateTopicsResult
org.apache.kafka.clients.admin.
CreateTopicsResult.TopicMetadataAndConfig
org.apache.kafka.common.metrics.stats.
CumulativeSum
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.metrics.stats.
CumulativeCount
org.apache.kafka.clients.admin.
DegradedBroker
org.apache.kafka.clients.admin.
DegradedBrokerComponent
org.apache.kafka.common.
DelegatingReconfigurable
(implements org.apache.kafka.common.
Reconfigurable
)
org.apache.kafka.common.security.token.delegation.
DelegationToken
org.apache.kafka.clients.admin.
DeleteAclsResult
org.apache.kafka.clients.admin.
DeleteAclsResult.FilterResult
org.apache.kafka.clients.admin.
DeleteAclsResult.FilterResults
org.apache.kafka.clients.admin.
DeleteClusterLinksResult
org.apache.kafka.clients.admin.
DeleteConsumerGroupOffsetsResult
org.apache.kafka.clients.admin.
DeleteConsumerGroupsResult
org.apache.kafka.clients.admin.
DeletedRecords
org.apache.kafka.clients.admin.
DeleteRecordsResult
org.apache.kafka.clients.admin.
DeleteTopicsResult
org.apache.kafka.clients.admin.
DemotedBroker
org.apache.kafka.clients.admin.
DescribeAclsResult
org.apache.kafka.clients.admin.
DescribeBalancerStatusResult
org.apache.kafka.clients.admin.
DescribeBrokerAdditionsResult
org.apache.kafka.clients.admin.
DescribeBrokerHealthResult
org.apache.kafka.clients.admin.
DescribeBrokerRemovalsResult
org.apache.kafka.clients.admin.
DescribeBrokerReplicaExclusionsResult
org.apache.kafka.clients.admin.
DescribeBrokerReplicaExclusionsResult.BrokerReplicaExclusionDescription
org.apache.kafka.clients.admin.
DescribeClientQuotasResult
org.apache.kafka.clients.admin.
DescribeClusterLinksResult
org.apache.kafka.clients.admin.
DescribeClusterResult
org.apache.kafka.clients.admin.
DescribeConfigsResult
org.apache.kafka.clients.admin.
DescribeConsumerGroupsResult
org.apache.kafka.clients.admin.
DescribeDelegationTokenResult
org.apache.kafka.clients.admin.
DescribeEvenClusterLoadStatusResult
org.apache.kafka.clients.admin.
DescribeFeaturesResult
org.apache.kafka.clients.admin.
DescribeLeadershipPriorityResult
org.apache.kafka.clients.admin.
DescribeLogDirsResult
org.apache.kafka.clients.admin.
DescribeMetadataQuorumResult
org.apache.kafka.clients.admin.
DescribeMirrorsResult
org.apache.kafka.clients.admin.
DescribeProducersResult
org.apache.kafka.clients.admin.
DescribeProducersResult.PartitionProducerState
org.apache.kafka.clients.admin.
DescribeReplicaLogDirsResult
org.apache.kafka.clients.admin.
DescribeReplicaLogDirsResult.ReplicaLogDirInfo
org.apache.kafka.clients.admin.
DescribeTopicsResult
org.apache.kafka.clients.admin.
DescribeTransactionsResult
org.apache.kafka.clients.admin.
DescribeUserScramCredentialsResult
org.apache.kafka.common.config.provider.
DirectoryConfigProvider
(implements org.apache.kafka.common.config.provider.
ConfigProvider
)
org.apache.kafka.common.serialization.
DoubleDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
DoubleSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.clients.admin.
ElectLeadersResult
org.apache.kafka.common.
Endpoint
org.apache.kafka.common.config.provider.
EnvVarConfigProvider
(implements org.apache.kafka.common.config.provider.
ConfigProvider
)
org.apache.kafka.clients.admin.
EvenClusterLoadPlan
org.apache.kafka.clients.admin.
EvenClusterLoadPlanBrokerRelatedStats
org.apache.kafka.clients.admin.
EvenClusterLoadPlanBrokerStats
org.apache.kafka.clients.admin.
EvenClusterLoadPlanClusterRelatedStats
org.apache.kafka.clients.admin.
EvenClusterLoadPlanDetailedClusterBalanceStats
org.apache.kafka.clients.admin.
EvenClusterLoadPlanGoalRelatedStats
org.apache.kafka.clients.admin.
EvenClusterLoadPlanGoalStats
org.apache.kafka.clients.admin.
EvenClusterLoadPlanGoalStatsOverview
org.apache.kafka.clients.admin.
EvenClusterLoadPlanGoalStatsOverviewRejectingGoal
org.apache.kafka.clients.admin.
EvenClusterLoadPlanGoalStatsResources
org.apache.kafka.clients.admin.
EvenClusterLoadPlanReplicaMovementStats
org.apache.kafka.clients.admin.
EvenClusterLoadStatusDescription
org.apache.kafka.clients.admin.
ExclusionOp
org.apache.kafka.clients.admin.
ExclusionOperationError
org.apache.kafka.clients.admin.
ExclusionOpResult
org.apache.kafka.clients.admin.
ExpireDelegationTokenResult
org.apache.kafka.clients.admin.
FeatureMetadata
org.apache.kafka.clients.admin.
FeatureUpdate
org.apache.kafka.clients.admin.
FenceProducersResult
org.apache.kafka.common.config.provider.
FileConfigProvider
(implements org.apache.kafka.common.config.provider.
ConfigProvider
)
org.apache.kafka.clients.admin.
FinalizedVersionRange
org.apache.kafka.common.serialization.
FloatDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
FloatSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.clients.admin.
ForwardingAdmin
(implements org.apache.kafka.clients.admin.
Admin
)
org.apache.kafka.common.metrics.stats.
Frequency
org.apache.kafka.common.metrics.stats.
Histogram
org.apache.kafka.common.metrics.stats.
Histogram.ConstantBinScheme
(implements org.apache.kafka.common.metrics.stats.
Histogram.BinScheme
)
org.apache.kafka.common.metrics.stats.
Histogram.LinearBinScheme
(implements org.apache.kafka.common.metrics.stats.
Histogram.BinScheme
)
org.apache.kafka.common.security.auth.
IdentityMetadata
org.apache.kafka.common.security.auth.
IdentityMetadata.Builder
org.apache.kafka.common.serialization.
IntegerDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
IntegerSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.common.annotation.
InterfaceStability
org.apache.kafka.common.metrics.
JmxReporter
(implements org.apache.kafka.common.metrics.
MetricsReporter
)
org.apache.kafka.clients.consumer.
KafkaConsumer
<K,V> (implements org.apache.kafka.clients.consumer.
Consumer
<K,V>)
org.apache.kafka.common.
KafkaFuture
<T> (implements java.util.concurrent.
Future
<V>)
org.apache.kafka.common.
KafkaFuture.Function
<A,B> (implements org.apache.kafka.common.
KafkaFuture.BaseFunction
<A,B>)
org.apache.kafka.common.metrics.
KafkaMetric
(implements org.apache.kafka.common.
Metric
)
org.apache.kafka.common.metrics.
KafkaMetricsContext
(implements org.apache.kafka.common.metrics.
MetricsContext
)
org.apache.kafka.common.security.auth.
KafkaPrincipal
(implements java.security.
Principal
)
org.apache.kafka.common.security.auth.
ConfluentPrincipal
org.apache.kafka.clients.producer.
KafkaProducer
<K,V> (implements org.apache.kafka.clients.producer.
Producer
<K,V>)
org.apache.kafka.clients.admin.
ListClientMetricsResourcesResult
org.apache.kafka.clients.admin.
ListClusterLinksResult
org.apache.kafka.clients.admin.
ListConsumerGroupOffsetsResult
org.apache.kafka.clients.admin.
ListConsumerGroupOffsetsSpec
org.apache.kafka.clients.admin.
ListConsumerGroupsResult
org.apache.kafka.common.serialization.
ListDeserializer
<Inner> (implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.clients.admin.
ListMirrorsResult
org.apache.kafka.clients.admin.
ListOffsetsResult
org.apache.kafka.clients.admin.
ListOffsetsResult.ListOffsetsResultInfo
org.apache.kafka.clients.admin.
ListPartitionReassignmentsResult
org.apache.kafka.common.serialization.
ListSerializer
<Inner> (implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.clients.admin.
ListTopicsResult
org.apache.kafka.clients.admin.
ListTransactionsResult
org.apache.kafka.clients.admin.
LogDirDescription
org.apache.kafka.common.config.
LogLevelConfig
org.apache.kafka.common.serialization.
LongDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
LongSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.clients.admin.
MemberAssignment
org.apache.kafka.clients.admin.
MemberDescription
org.apache.kafka.clients.admin.
MemberToRemove
org.apache.kafka.common.metrics.stats.
Meter
(implements org.apache.kafka.common.metrics.
CompoundStat
)
org.apache.kafka.common.metrics.
MetricConfig
org.apache.kafka.common.
MetricName
org.apache.kafka.common.
MetricNameTemplate
org.apache.kafka.common.metrics.
Metrics
(implements java.io.
Closeable
)
org.apache.kafka.clients.admin.
MirrorTopicDescription
org.apache.kafka.clients.consumer.
MockConsumer
<K,V> (implements org.apache.kafka.clients.consumer.
Consumer
<K,V>)
org.apache.kafka.clients.producer.
MockProducer
<K,V> (implements org.apache.kafka.clients.producer.
Producer
<K,V>)
org.apache.kafka.clients.admin.
NewClusterLink
org.apache.kafka.clients.admin.
NewMirrorTopic
org.apache.kafka.clients.admin.
NewPartitionReassignment
org.apache.kafka.clients.admin.
NewPartitions
org.apache.kafka.clients.admin.
NewTopic
org.apache.kafka.common.
Node
org.apache.kafka.common.
ConfluentNode
org.apache.kafka.common.security.oauthbearer.
OAuthBearerLoginCallbackHandler
(implements org.apache.kafka.common.security.auth.
AuthenticateCallbackHandler
)
org.apache.kafka.common.security.oauthbearer.secured.
OAuthBearerLoginCallbackHandler
org.apache.kafka.common.security.oauthbearer.
OAuthBearerLoginModule
(implements javax.security.auth.spi.
LoginModule
)
org.apache.kafka.common.security.oauthbearer.
OAuthBearerTokenCallback
(implements javax.security.auth.callback.
Callback
)
org.apache.kafka.common.security.oauthbearer.
OAuthBearerValidatorCallback
(implements javax.security.auth.callback.
Callback
, org.apache.kafka.common.security.oauthbearer.
Contextable
)
org.apache.kafka.common.security.oauthbearer.
OAuthBearerValidatorCallbackHandler
(implements org.apache.kafka.common.security.auth.
AuthenticateCallbackHandler
)
org.apache.kafka.common.security.oauthbearer.secured.
OAuthBearerValidatorCallbackHandler
org.apache.kafka.clients.consumer.
OffsetAndMetadata
(implements java.io.
Serializable
)
org.apache.kafka.clients.consumer.
OffsetAndTimestamp
org.apache.kafka.clients.admin.
OffsetSpec
org.apache.kafka.clients.admin.
OffsetSpec.EarliestSpec
org.apache.kafka.clients.admin.
OffsetSpec.LatestSpec
org.apache.kafka.clients.admin.
OffsetSpec.MaxTimestampSpec
org.apache.kafka.clients.admin.
OffsetSpec.TimestampSpec
org.apache.kafka.common.
PartitionInfo
org.apache.kafka.clients.admin.
PartitionReassignment
org.apache.kafka.clients.admin.
PartitionResult
org.apache.kafka.common.metrics.stats.
Percentile
org.apache.kafka.common.security.plain.
PlainAuthenticateCallback
(implements javax.security.auth.callback.
Callback
)
org.apache.kafka.common.security.plain.
PlainLoginModule
(implements javax.security.auth.spi.
LoginModule
)
org.apache.kafka.common.security.auth.
PlaintextAuthenticationContext
(implements org.apache.kafka.common.security.auth.
AuthenticationContext
)
org.apache.kafka.clients.producer.
ProducerRecord
<K,V>
org.apache.kafka.clients.admin.
ProducerState
org.apache.kafka.clients.admin.
QuorumInfo
org.apache.kafka.clients.admin.
QuorumInfo.ReplicaState
org.apache.kafka.common.metrics.
Quota
org.apache.kafka.common.metrics.stats.
Rate
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.metrics.stats.
SimpleRate
org.apache.kafka.clients.producer.
RecordMetadata
org.apache.kafka.clients.admin.
RecordsToDelete
org.apache.kafka.clients.admin.
RemoveBrokersResult
org.apache.kafka.clients.admin.
RemoveMembersFromConsumerGroupResult
org.apache.kafka.clients.admin.
RenewDelegationTokenResult
org.apache.kafka.clients.admin.
ReplicaInfo
org.apache.kafka.clients.admin.
ReplicaStatusResult
org.apache.kafka.common.resource.
Resource
org.apache.kafka.common.resource.
ResourcePattern
org.apache.kafka.common.resource.
ResourcePatternFilter
org.apache.kafka.clients.producer.
RoundRobinPartitioner
(implements org.apache.kafka.clients.producer.
Partitioner
)
org.apache.kafka.common.metrics.stats.
SampledStat
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.metrics.stats.
Avg
org.apache.kafka.common.metrics.stats.
ExponentialWeightedAvg
org.apache.kafka.common.metrics.stats.
Frequencies
(implements org.apache.kafka.common.metrics.
CompoundStat
)
org.apache.kafka.common.metrics.stats.
Max
org.apache.kafka.common.metrics.stats.
Min
org.apache.kafka.common.metrics.stats.
Percentiles
(implements org.apache.kafka.common.metrics.
CompoundStat
)
org.apache.kafka.common.metrics.stats.
WindowedSum
org.apache.kafka.common.metrics.stats.
WindowedCount
org.apache.kafka.common.security.auth.
SaslAuthenticationContext
(implements org.apache.kafka.common.security.auth.
AuthenticationContext
)
org.apache.kafka.common.config.
SaslConfigs
org.apache.kafka.common.security.auth.
SaslExtensions
org.apache.kafka.common.security.auth.
SaslExtensionsCallback
(implements javax.security.auth.callback.
Callback
)
org.apache.kafka.common.security.scram.
ScramCredential
org.apache.kafka.common.security.scram.
ScramCredentialCallback
(implements javax.security.auth.callback.
Callback
)
org.apache.kafka.clients.admin.
ScramCredentialInfo
org.apache.kafka.common.security.scram.
ScramExtensionsCallback
(implements javax.security.auth.callback.
Callback
)
org.apache.kafka.common.security.scram.
ScramLoginModule
(implements javax.security.auth.spi.
LoginModule
)
org.apache.kafka.common.config.
SecurityConfig
org.apache.kafka.common.metrics.
Sensor
org.apache.kafka.common.serialization.
Serdes
org.apache.kafka.common.serialization.
Serdes.WrapperSerde
<T> (implements org.apache.kafka.common.serialization.
Serde
<T>)
org.apache.kafka.common.serialization.
Serdes.BooleanSerde
org.apache.kafka.common.serialization.
Serdes.ByteArraySerde
org.apache.kafka.common.serialization.
Serdes.ByteBufferSerde
org.apache.kafka.common.serialization.
Serdes.BytesSerde
org.apache.kafka.common.serialization.
Serdes.DoubleSerde
org.apache.kafka.common.serialization.
Serdes.FloatSerde
org.apache.kafka.common.serialization.
Serdes.IntegerSerde
org.apache.kafka.common.serialization.
Serdes.ListSerde
<Inner>
org.apache.kafka.common.serialization.
Serdes.LongSerde
org.apache.kafka.common.serialization.
Serdes.ShortSerde
org.apache.kafka.common.serialization.
Serdes.StringSerde
org.apache.kafka.common.serialization.
Serdes.UUIDSerde
org.apache.kafka.common.serialization.
Serdes.VoidSerde
org.apache.kafka.common.serialization.
ShortDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
ShortSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.common.security.auth.
SslAuthenticationContext
(implements org.apache.kafka.common.security.auth.
AuthenticationContext
)
org.apache.kafka.common.config.
SslConfigs
org.apache.kafka.common.serialization.
StringDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
StringSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.clients.admin.
SupportedVersionRange
org.apache.kafka.common.
Tenant
java.lang.
Throwable
(implements java.io.
Serializable
)
java.lang.
Exception
java.lang.
RuntimeException
org.apache.kafka.common.
KafkaException
org.apache.kafka.common.errors.
ApiException
org.apache.kafka.common.errors.
AuthenticationException
org.apache.kafka.common.errors.
IllegalSaslStateException
org.apache.kafka.common.errors.
SaslAuthenticationException
org.apache.kafka.common.errors.
AuthenticationTimeoutException
org.apache.kafka.common.errors.
SslAuthenticationException
org.apache.kafka.common.errors.
UnsupportedSaslMechanismException
org.apache.kafka.common.errors.
AuthorizationException
org.apache.kafka.common.errors.
ClusterAuthorizationException
org.apache.kafka.common.errors.
DelegationTokenAuthorizationException
org.apache.kafka.common.errors.
GroupAuthorizationException
org.apache.kafka.common.errors.
TopicAuthorizationException
org.apache.kafka.common.errors.
TransactionalIdAuthorizationException
org.apache.kafka.common.errors.
BalanceCannotBeImprovedException
org.apache.kafka.common.errors.
BalancerBrokerExcludedForReplicaPlacementException
org.apache.kafka.common.errors.
BalancerLoadError
org.apache.kafka.common.errors.
BalancerMisconfigurationException
org.apache.kafka.common.errors.
BalancerJbodEnabledMisconfigurationException
org.apache.kafka.common.errors.
BalancerOfflineException
org.apache.kafka.common.errors.
BalancerOperationFailedException
org.apache.kafka.common.errors.
BrokerAdditionInProgressException
org.apache.kafka.common.errors.
BrokerFailureFixInProgressException
org.apache.kafka.common.errors.
BrokerIdNotRegisteredException
org.apache.kafka.common.errors.
BrokerNotAvailableException
org.apache.kafka.common.errors.
BrokerRegistrationDoesNotContainActiveSecretException
org.apache.kafka.common.errors.
BrokerRemovalCanceledException
org.apache.kafka.common.errors.
BrokerRemovalInProgressException
org.apache.kafka.common.errors.
BrokerRemovedException
org.apache.kafka.common.errors.
CellNotFoundException
org.apache.kafka.common.errors.
ClusterLinkDisabledException
org.apache.kafka.common.errors.
ClusterLinkExistsException
org.apache.kafka.common.errors.
ClusterLinkInUseException
org.apache.kafka.common.errors.
ClusterLinkNotFoundException
org.apache.kafka.common.errors.
ClusterLinkPausedException
org.apache.kafka.common.errors.
ControllerMovedException
org.apache.kafka.common.errors.
ControllerRegistrationDoesNotContainActiveSecretException
org.apache.kafka.common.errors.
DelegationTokenDisabledException
org.apache.kafka.common.errors.
DelegationTokenExpiredException
org.apache.kafka.common.errors.
DelegationTokenNotFoundException
org.apache.kafka.common.errors.
DelegationTokenOwnerMismatchException
org.apache.kafka.common.errors.
DemotionLimitReachedException
org.apache.kafka.common.errors.
DuplicateBrokerRegistrationException
org.apache.kafka.common.errors.
DuplicateResourceException
org.apache.kafka.common.errors.
DuplicateSequenceException
org.apache.kafka.common.errors.
EvenClusterLoadTaskInProgressException
org.apache.kafka.common.errors.
FeatureUpdateFailedException
org.apache.kafka.common.errors.
FencedInstanceIdException
org.apache.kafka.common.errors.
FencedMemberEpochException
org.apache.kafka.common.errors.
FencedReplicationSessionIdException
org.apache.kafka.common.errors.
GroupIdNotFoundException
org.apache.kafka.common.errors.
GroupMaxSizeReachedException
org.apache.kafka.common.errors.
GroupNotEmptyException
org.apache.kafka.common.errors.
GroupSubscribedToTopicException
org.apache.kafka.common.errors.
IllegalGenerationException
org.apache.kafka.common.errors.
InconsistentClusterIdException
org.apache.kafka.common.errors.
InconsistentGroupProtocolException
org.apache.kafka.common.errors.
InconsistentVoterSetException
org.apache.kafka.common.errors.
IneligibleReplicaException
org.apache.kafka.common.errors.
InsufficientDataForCellLoadComputationException
org.apache.kafka.common.errors.
InvalidBrokerRemovalException
org.apache.kafka.common.errors.
InvalidBrokerReplicaExclusionException
org.apache.kafka.common.errors.
BrokerReplicaExclusionNotFoundException
org.apache.kafka.common.errors.
InvalidClusterLinkException
org.apache.kafka.common.errors.
InvalidCommitOffsetSizeException
org.apache.kafka.common.errors.
InvalidConfigurationException
org.apache.kafka.common.errors.
InvalidFetchSizeException
org.apache.kafka.common.errors.
InvalidGroupIdException
org.apache.kafka.common.errors.
InvalidOffsetException
org.apache.kafka.common.errors.
OffsetOutOfRangeException
org.apache.kafka.common.errors.
InvalidPartitionsException
org.apache.kafka.common.errors.
InvalidPidMappingException
org.apache.kafka.common.errors.
InvalidPrincipalTypeException
org.apache.kafka.common.errors.
InvalidProducerEpochException
org.apache.kafka.common.
InvalidRecordException
org.apache.kafka.common.errors.
InvalidRegistrationException
org.apache.kafka.common.errors.
InvalidReplicaAssignmentException
org.apache.kafka.common.errors.
InvalidReplicationFactorException
org.apache.kafka.common.errors.
InvalidReplicationOffsetException
org.apache.kafka.common.errors.
InvalidRequestException
org.apache.kafka.common.errors.
InvalidRequiredAcksException
org.apache.kafka.common.errors.
InvalidSessionTimeoutException
org.apache.kafka.common.errors.
InvalidTimestampException
org.apache.kafka.common.errors.
InvalidTopicException
org.apache.kafka.common.errors.
InvalidTxnStateException
org.apache.kafka.common.errors.
InvalidTxnTimeoutException
org.apache.kafka.common.errors.
InvalidUpdateVersionException
org.apache.kafka.common.errors.
LogDirNotFoundException
org.apache.kafka.common.errors.
MemberIdRequiredException
org.apache.kafka.common.errors.
MismatchedEndpointTypeException
org.apache.kafka.common.errors.
NewLeaderElectedException
org.apache.kafka.common.errors.
NoReassignmentInProgressException
org.apache.kafka.common.errors.
OffsetMetadataTooLarge
org.apache.kafka.common.errors.
OffsetMovedToTieredStorageException
org.apache.kafka.common.errors.
OffsetTieredException
org.apache.kafka.common.errors.
OperationNotAttemptedException
org.apache.kafka.common.errors.
OutOfOrderSequenceException
org.apache.kafka.common.errors.
UnknownProducerIdException
org.apache.kafka.common.errors.
PolicyViolationException
org.apache.kafka.common.errors.
PositionOutOfRangeException
org.apache.kafka.common.errors.
PrincipalDeserializationException
org.apache.kafka.common.errors.
ProducerFencedException
org.apache.kafka.common.errors.
PushReplicationStartedException
org.apache.kafka.common.errors.
QuotaEntityNotFoundException
org.apache.kafka.common.errors.
ReassignmentInProgressException
org.apache.kafka.common.errors.
RebalanceInProgressException
org.apache.kafka.common.errors.
RebalancePlanComputationException
org.apache.kafka.common.errors.
InsufficientRebalancePlanMetricsException
org.apache.kafka.common.errors.
RebalanceInProgressDuringPlanComputationException
org.apache.kafka.common.errors.
RecordBatchTooLargeException
org.apache.kafka.common.errors.
RecordTooLargeException
org.apache.kafka.common.errors.
ResourceNotFoundException
org.apache.kafka.common.errors.
RetriableException
org.apache.kafka.common.errors.
AuthorizerNotReadyException
org.apache.kafka.common.errors.
ConcurrentTransactionsException
org.apache.kafka.common.errors.
CoordinatorLoadInProgressException
org.apache.kafka.common.errors.
CoordinatorNotAvailableException
org.apache.kafka.common.errors.
CorruptRecordException
org.apache.kafka.common.errors.
DisconnectException
org.apache.kafka.common.errors.
FetchSessionIdNotFoundException
org.apache.kafka.common.errors.
FetchSessionTopicIdException
org.apache.kafka.common.errors.
InvalidFetchSessionEpochException
org.apache.kafka.common.errors.
InvalidMetadataException
org.apache.kafka.common.errors.
ElectionNotNeededException
org.apache.kafka.common.errors.
EligibleLeadersNotAvailableException
org.apache.kafka.common.errors.
FencedLeaderEpochException
org.apache.kafka.common.errors.
InconsistentTopicIdException
org.apache.kafka.common.errors.
KafkaStorageException
org.apache.kafka.common.errors.
LeaderNotAvailableException
org.apache.kafka.common.errors.
ListenerNotFoundException
org.apache.kafka.common.errors.
NetworkException
org.apache.kafka.common.errors.
NotLeaderForPartitionException
org.apache.kafka.common.errors.
NotLeaderOrFollowerException
org.apache.kafka.common.errors.
PreferredLeaderNotAvailableException
org.apache.kafka.common.errors.
ReplicaNotAvailableException
org.apache.kafka.common.errors.
UnknownTopicIdException
org.apache.kafka.common.errors.
UnknownTopicOrPartitionException
org.apache.kafka.common.errors.
NotControllerException
org.apache.kafka.common.errors.
NotCoordinatorException
org.apache.kafka.common.errors.
NotEnoughReplicasAfterAppendException
org.apache.kafka.common.errors.
NotEnoughReplicasException
org.apache.kafka.common.errors.
OffsetNotAvailableException
org.apache.kafka.clients.consumer.
RetriableCommitFailedException
org.apache.kafka.common.errors.
ThrottlingQuotaExceededException
org.apache.kafka.common.errors.
TimeoutException
org.apache.kafka.clients.producer.
BufferExhaustedException
org.apache.kafka.common.errors.
UnknownLeaderEpochException
org.apache.kafka.common.errors.
UnstableOffsetCommitException
org.apache.kafka.common.errors.
SecurityDisabledException
org.apache.kafka.common.errors.
SnapshotNotFoundException
org.apache.kafka.common.errors.
StaleBrokerEpochException
org.apache.kafka.common.errors.
StaleMemberEpochException
org.apache.kafka.common.errors.
TelemetryTooLargeException
org.apache.kafka.common.errors.
TenantNotFoundException
org.apache.kafka.common.errors.
TopicDeletionDisabledException
org.apache.kafka.common.errors.
TopicExistsException
org.apache.kafka.common.errors.
TransactionAbortedException
org.apache.kafka.common.errors.
TransactionalIdNotFoundException
org.apache.kafka.common.errors.
TransactionCoordinatorFencedException
org.apache.kafka.common.errors.
UnacceptableCredentialException
org.apache.kafka.common.errors.
UnknownControllerIdException
org.apache.kafka.common.errors.
UnknownMemberIdException
org.apache.kafka.common.errors.
UnknownServerException
org.apache.kafka.common.errors.
UnknownSubscriptionIdException
org.apache.kafka.common.errors.
UnreleasedInstanceIdException
org.apache.kafka.common.errors.
UnrepresentableBrokerIdException
org.apache.kafka.common.errors.
UnsupportedAssignorException
org.apache.kafka.common.errors.
UnsupportedByAuthenticationException
org.apache.kafka.common.errors.
UnsupportedCompressionTypeException
org.apache.kafka.common.errors.
UnsupportedEndpointTypeException
org.apache.kafka.common.errors.
UnsupportedForMessageFormatException
org.apache.kafka.common.errors.
UnsupportedVersionException
org.apache.kafka.clients.consumer.
CommitFailedException
org.apache.kafka.common.config.
ConfigException
org.apache.kafka.common.errors.
InterruptException
org.apache.kafka.clients.consumer.
InvalidOffsetException
org.apache.kafka.clients.consumer.
NoOffsetForPartitionException
org.apache.kafka.clients.consumer.
OffsetOutOfRangeException
org.apache.kafka.clients.consumer.
LogTruncationException
org.apache.kafka.common.metrics.
QuotaViolationException
org.apache.kafka.common.errors.
SecretsLogFailedException
org.apache.kafka.common.errors.
SerializationException
org.apache.kafka.common.errors.
RecordDeserializationException
org.apache.kafka.common.errors.
WakeupException
org.apache.kafka.common.errors.
MultiChecksumTypeException
org.apache.kafka.common.errors.
OtherChecksumTypeException
org.apache.kafka.common.metrics.stats.
TokenBucket
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.metrics.stats.
MinTokenBucket
org.apache.kafka.common.security.token.delegation.
TokenInformation
org.apache.kafka.common.
TopicCollection
org.apache.kafka.common.
TopicCollection.TopicIdCollection
org.apache.kafka.common.
TopicCollection.TopicNameCollection
org.apache.kafka.common.config.
TopicConfig
org.apache.kafka.clients.admin.
TopicDescription
org.apache.kafka.common.
TopicIdPartition
org.apache.kafka.clients.admin.
TopicListing
org.apache.kafka.common.
TopicPartition
(implements java.io.
Serializable
)
org.apache.kafka.common.
TopicPartitionInfo
org.apache.kafka.common.
TopicPartitionReplica
(implements java.io.
Serializable
)
org.apache.kafka.clients.admin.
TransactionDescription
org.apache.kafka.clients.admin.
TransactionListing
org.apache.kafka.clients.admin.
TriggerEvenClusterLoadResult
org.apache.kafka.clients.producer.
UniformStickyPartitioner
(implements org.apache.kafka.clients.producer.
Partitioner
)
org.apache.kafka.clients.admin.
UnregisterBrokerResult
org.apache.kafka.clients.admin.
UpdateFeaturesResult
org.apache.kafka.clients.admin.
UserScramCredentialAlteration
org.apache.kafka.clients.admin.
UserScramCredentialDeletion
org.apache.kafka.clients.admin.
UserScramCredentialUpsertion
org.apache.kafka.clients.admin.
UserScramCredentialsDescription
org.apache.kafka.common.
Uuid
(implements java.lang.
Comparable
<T>)
org.apache.kafka.common.serialization.
UUIDDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
UUIDSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.common.metrics.stats.
Value
(implements org.apache.kafka.common.metrics.
MeasurableStat
)
org.apache.kafka.common.serialization.
VoidDeserializer
(implements org.apache.kafka.common.serialization.
Deserializer
<T>)
org.apache.kafka.common.serialization.
VoidSerializer
(implements org.apache.kafka.common.serialization.
Serializer
<T>)
org.apache.kafka.server.quota.
ZkClientQuotaClusterDescriber
(implements org.apache.kafka.server.quota.
ClientQuotaClusterDescriber
)
org.apache.kafka.server.quota.
ZkClientQuotaClusterDescriber.PartitionIterator
(implements java.util.
Iterator
<E>)
Interface Hierarchy
org.apache.kafka.common.acl.
AclUpdateListener
org.apache.kafka.common.security.auth.
AuthenticationContext
org.apache.kafka.server.authorizer.
AuthorizableRequestContext
org.apache.kafka.common.security.auth.
AuthorizationIdProvider
org.apache.kafka.server.authorizer.
AuthorizerServerInfo
java.lang.
AutoCloseable
org.apache.kafka.clients.admin.
Admin
org.apache.kafka.clients.admin.
ConfluentAdmin
org.apache.kafka.server.policy.
AlterConfigPolicy
(also extends org.apache.kafka.common.
Configurable
)
java.io.
Closeable
org.apache.kafka.server.authorizer.
Authorizer
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.common.config.provider.
ConfigProvider
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.clients.consumer.
Consumer
<K,V>
org.apache.kafka.common.serialization.
Deserializer
<T>
org.apache.kafka.common.
MessageFormatter
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.server.quota.
MultiTenantQuotaConsumer
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.clients.producer.
Partitioner
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.clients.producer.
Producer
<K,V>
org.apache.kafka.common.serialization.
Serde
<T>
org.apache.kafka.common.serialization.
Serializer
<T>
org.apache.kafka.common.security.auth.
SslEngineFactory
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.clients.consumer.
ConsumerInterceptor
<K,V> (also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.server.policy.
CreateTopicPolicy
(also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.common.metrics.
MetricsReporter
(also extends org.apache.kafka.common.
Reconfigurable
)
org.apache.kafka.clients.producer.
ProducerInterceptor
<K,V> (also extends org.apache.kafka.common.
Configurable
)
org.apache.kafka.clients.producer.
Callback
javax.security.auth.callback.
CallbackHandler
org.apache.kafka.common.security.auth.
AuthenticateCallbackHandler
org.apache.kafka.server.quota.
ClientQuotaClusterDescriber
org.apache.kafka.server.quota.
ClientQuotaEntity
org.apache.kafka.server.quota.
ClientQuotaEntity.ConfigEntity
org.apache.kafka.server.telemetry.
ClientTelemetry
org.apache.kafka.server.telemetry.
ClientTelemetryPayload
org.apache.kafka.server.telemetry.
ClientTelemetryReceiver
org.apache.kafka.server.quota.
ClusterLevelQuotaCallback
org.apache.kafka.common.
ClusterResourceListener
org.apache.kafka.common.config.
ConfigChangeCallback
org.apache.kafka.common.config.
ConfigDef.Recommender
org.apache.kafka.common.config.
ConfigDef.Validator
org.apache.kafka.common.
Configurable
org.apache.kafka.server.policy.
AlterConfigPolicy
(also extends java.lang.
AutoCloseable
)
org.apache.kafka.server.authorizer.
Authorizer
(also extends java.io.
Closeable
)
org.apache.kafka.server.quota.
ClientQuotaCallback
org.apache.kafka.common.config.provider.
ConfigProvider
(also extends java.io.
Closeable
)
org.apache.kafka.clients.consumer.
ConsumerInterceptor
<K,V> (also extends java.lang.
AutoCloseable
)
org.apache.kafka.server.policy.
CreateClusterLinkPolicy
org.apache.kafka.server.policy.
CreateTopicPolicy
(also extends java.lang.
AutoCloseable
)
org.apache.kafka.common.
MessageFormatter
(also extends java.io.
Closeable
)
org.apache.kafka.common.metrics.
MetricsReporter
(also extends java.lang.
AutoCloseable
, org.apache.kafka.common.
Reconfigurable
)
org.apache.kafka.server.quota.
MultiTenantQuotaConsumer
(also extends java.io.
Closeable
)
org.apache.kafka.clients.producer.
Partitioner
(also extends java.io.
Closeable
)
org.apache.kafka.clients.producer.
ProducerInterceptor
<K,V> (also extends java.lang.
AutoCloseable
)
org.apache.kafka.common.
Reconfigurable
org.apache.kafka.common.metrics.
MetricsReporter
(also extends java.lang.
AutoCloseable
)
org.apache.kafka.common.security.auth.
SecurityProviderCreator
org.apache.kafka.common.security.auth.
SslEngineFactory
(also extends java.io.
Closeable
)
org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor
org.apache.kafka.clients.consumer.
ConsumerRebalanceListener
org.apache.kafka.common.security.oauthbearer.
Contextable
org.apache.kafka.common.header.
Header
org.apache.kafka.common.metrics.stats.
Histogram.BinScheme
java.lang.
Iterable
<T>
org.apache.kafka.common.header.
Headers
org.apache.kafka.common.
KafkaFuture.BaseFunction
<A,B>
org.apache.kafka.common.
KafkaFuture.BiConsumer
<A,B>
org.apache.kafka.common.security.auth.
KafkaPrincipalBuilder
org.apache.kafka.common.security.auth.
KafkaPrincipalSerde
org.apache.kafka.common.security.auth.
Login
org.apache.kafka.common.
Metric
org.apache.kafka.common.metrics.
MetricsContext
org.apache.kafka.common.metrics.
MetricValueProvider
<T>
org.apache.kafka.common.metrics.
Gauge
<T>
org.apache.kafka.common.metrics.
Measurable
org.apache.kafka.common.metrics.
MeasurableStat
(also extends org.apache.kafka.common.metrics.
Stat
)
org.apache.kafka.common.metrics.
MeasurableStat
(also extends org.apache.kafka.common.metrics.
Measurable
, org.apache.kafka.common.metrics.
Stat
)
org.apache.kafka.common.security.oauthbearer.
OAuthBearerToken
org.apache.kafka.clients.consumer.
OffsetCommitCallback
org.apache.kafka.common.metrics.
Stat
org.apache.kafka.common.metrics.
CompoundStat
org.apache.kafka.common.metrics.
MeasurableStat
(also extends org.apache.kafka.common.metrics.
Measurable
)
Annotation Type Hierarchy
org.apache.kafka.common.
Confluent
(implements java.lang.annotation.
Annotation
)
org.apache.kafka.common.annotation.
InterfaceStability.Evolving
(implements java.lang.annotation.
Annotation
)
org.apache.kafka.common.annotation.
InterfaceStability.Stable
(implements java.lang.annotation.
Annotation
)
org.apache.kafka.common.annotation.
InterfaceStability.Unstable
(implements java.lang.annotation.
Annotation
)
Enum Hierarchy
java.lang.
Object
java.lang.
Enum
<E> (implements java.lang.
Comparable
<T>, java.io.
Serializable
)
org.apache.kafka.common.acl.
AclOperation
org.apache.kafka.common.acl.
AclPermissionType
org.apache.kafka.common.acl.
AclState
org.apache.kafka.clients.admin.
AlterConfigOp.OpType
org.apache.kafka.clients.admin.
AlterLeadershipPrioritySpec.PriorityOperationEnum
org.apache.kafka.clients.admin.
AlterMirrorOp
org.apache.kafka.server.authorizer.
AuthorizationResult
org.apache.kafka.clients.admin.
BalancerOperationStatus
org.apache.kafka.clients.admin.
BalancerSelfHealMode
org.apache.kafka.clients.admin.
BalancerStatus
org.apache.kafka.clients.admin.
BrokerComponent
org.apache.kafka.clients.admin.
BrokerLeadershipPriorityResult.LeadershipPriorityEnum
org.apache.kafka.clients.admin.
BrokerReplicaExclusionStatus
org.apache.kafka.clients.admin.
BrokerShutdownStatus
org.apache.kafka.common.
CellMigrationState
org.apache.kafka.common.
CellState
org.apache.kafka.server.quota.
ClientQuotaEntity.ConfigEntityType
org.apache.kafka.server.quota.
ClientQuotaType
org.apache.kafka.clients.admin.
ClusterLinkDescription.ConnectionMode
org.apache.kafka.clients.admin.
ClusterLinkDescription.LinkMode
org.apache.kafka.clients.admin.
ClusterLinkDescription.LinkState
org.apache.kafka.common.
ClusterLinkError
org.apache.kafka.clients.admin.
ClusterLinkTaskDescription.ClusterLinkTaskState
org.apache.kafka.clients.admin.
ClusterLinkTaskError.ClusterLinkTaskErrorCode
org.apache.kafka.clients.admin.
ComponentHealthStatus
org.apache.kafka.common.config.
ConfigDef.Importance
org.apache.kafka.common.config.
ConfigDef.Type
org.apache.kafka.common.config.
ConfigDef.Width
org.apache.kafka.clients.admin.
ConfigEntry.ConfigSource
org.apache.kafka.clients.admin.
ConfigEntry.ConfigType
org.apache.kafka.common.config.
ConfigResource.Type
org.apache.kafka.common.
ConsumerGroupState
org.apache.kafka.clients.consumer.
ConsumerPartitionAssignor.RebalanceProtocol
org.apache.kafka.server.quota.
ElasticCkuDefinitionKey
org.apache.kafka.common.
ElectionType
org.apache.kafka.clients.admin.
EndpointType
org.apache.kafka.clients.admin.
EvenClusterLoadStatus
org.apache.kafka.clients.admin.
ExclusionOp.OpType
org.apache.kafka.clients.admin.
FeatureUpdate.UpgradeType
org.apache.kafka.clients.consumer.
GroupProtocol
org.apache.kafka.common.
GroupType
org.apache.kafka.common.
IsolationLevel
org.apache.kafka.clients.admin.
MirrorTopicDescription.State
org.apache.kafka.common.
MirrorTopicError
org.apache.kafka.clients.consumer.
OffsetResetStrategy
org.apache.kafka.common.
PartitionPlacementStrategy
org.apache.kafka.clients.admin.
PartitionReassignmentsStatus
org.apache.kafka.common.resource.
PatternType
org.apache.kafka.common.metrics.stats.
Percentiles.BucketSizing
org.apache.kafka.common.resource.
ResourceType
org.apache.kafka.clients.admin.
ScramMechanism
org.apache.kafka.common.security.auth.
SecurityProtocol
org.apache.kafka.common.metrics.
Sensor.RecordingLevel
org.apache.kafka.common.config.
SslClientAuth
org.apache.kafka.clients.admin.
TransactionState
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes