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