All Classes
- AbortTransactionOptions
- AbortTransactionResult
- AbortTransactionSpec
- AbstractConfig
- AbstractOptions
- AccessControlEntry
- AccessControlEntryFilter
- AclBinding
- AclBindingFilter
- AclCreateResult
- AclDeleteResult
- AclDeleteResult.AclBindingDeleteResult
- AclOperation
- AclPermissionType
- Action
- Admin
- AdminClient
- AdminClientConfig
- AlterClientQuotasOptions
- AlterClientQuotasResult
- AlterConfigOp
- AlterConfigOp.OpType
- AlterConfigPolicy
- AlterConfigPolicy.RequestMetadata
- AlterConfigsOptions
- AlterConfigsResult
- AlterConsumerGroupOffsetsOptions
- AlterConsumerGroupOffsetsResult
- AlterPartitionReassignmentsOptions
- AlterPartitionReassignmentsResult
- AlterReplicaLogDirsOptions
- AlterReplicaLogDirsResult
- AlterUserScramCredentialsOptions
- AlterUserScramCredentialsResult
- ApiException
- AuthenticateCallbackHandler
- AuthenticationContext
- AuthenticationException
- AuthorizableRequestContext
- AuthorizationException
- AuthorizationResult
- Authorizer
- AuthorizerNotReadyException
- AuthorizerServerInfo
- Avg
- BooleanDeserializer
- BooleanSerializer
- BrokerIdNotRegisteredException
- BrokerNotAvailableException
- BufferExhaustedException
- ByteArrayDeserializer
- ByteArraySerializer
- ByteBufferDeserializer
- ByteBufferSerializer
- BytesDeserializer
- BytesSerializer
- Callback
- ClientQuotaAlteration
- ClientQuotaAlteration.Op
- ClientQuotaCallback
- ClientQuotaEntity
- ClientQuotaEntity
- ClientQuotaEntity.ConfigEntity
- ClientQuotaEntity.ConfigEntityType
- ClientQuotaFilter
- ClientQuotaFilterComponent
- ClientQuotaType
- Cluster
- ClusterAuthorizationException
- ClusterResource
- ClusterResourceListener
- CommitFailedException
- CompoundStat
- CompoundStat.NamedMeasurable
- ConcurrentTransactionsException
- Config
- Config
- ConfigChangeCallback
- ConfigData
- ConfigDef
- ConfigDef.CaseInsensitiveValidString
- ConfigDef.CompositeValidator
- ConfigDef.ConfigKey
- ConfigDef.Importance
- 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
- 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
- CreateDelegationTokenOptions
- CreateDelegationTokenResult
- CreatePartitionsOptions
- CreatePartitionsResult
- CreateTopicPolicy
- CreateTopicPolicy.RequestMetadata
- CreateTopicsOptions
- CreateTopicsResult
- CreateTopicsResult.TopicMetadataAndConfig
- CumulativeCount
- CumulativeSum
- DefaultStreamsPartitioner
- DelegationToken
- DelegationTokenAuthorizationException
- DelegationTokenDisabledException
- DelegationTokenExpiredException
- DelegationTokenNotFoundException
- DelegationTokenOwnerMismatchException
- DeleteAclsOptions
- DeleteAclsResult
- DeleteAclsResult.FilterResult
- DeleteAclsResult.FilterResults
- DeleteConsumerGroupOffsetsOptions
- DeleteConsumerGroupOffsetsResult
- DeleteConsumerGroupsOptions
- DeleteConsumerGroupsResult
- DeletedRecords
- DeleteRecordsOptions
- DeleteRecordsResult
- DeleteTopicsOptions
- DeleteTopicsResult
- DescribeAclsOptions
- DescribeAclsResult
- DescribeClientQuotasOptions
- DescribeClientQuotasResult
- DescribeClusterOptions
- DescribeClusterResult
- DescribeConfigsOptions
- DescribeConfigsResult
- DescribeConsumerGroupsOptions
- DescribeConsumerGroupsResult
- DescribeDelegationTokenOptions
- DescribeDelegationTokenResult
- DescribeFeaturesOptions
- DescribeFeaturesResult
- DescribeLogDirsOptions
- DescribeLogDirsResult
- DescribeMetadataQuorumOptions
- DescribeMetadataQuorumResult
- 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
- ExpireDelegationTokenOptions
- ExpireDelegationTokenResult
- 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
- IntegerDeserializer
- IntegerSerializer
- InterfaceStability
- InterfaceStability.Evolving
- InterfaceStability.Stable
- InterfaceStability.Unstable
- InterruptException
- 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
- ListConsumerGroupOffsetsOptions
- ListConsumerGroupOffsetsResult
- ListConsumerGroupOffsetsSpec
- ListConsumerGroupsOptions
- ListConsumerGroupsResult
- ListDeserializer
- ListenerNotFoundException
- 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
- MockConsumer
- MockProducer
- NetworkException
- NewLeaderElectedException
- 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
- OperationNotAttemptedException
- OutOfOrderSequenceException
- Partitioner
- PartitionInfo
- PartitionReassignment
- PatternType
- Percentile
- Percentiles
- Percentiles.BucketSizing
- PlainAuthenticateCallback
- PlainLoginModule
- PlaintextAuthenticationContext
- PolicyViolationException
- PositionOutOfRangeException
- PreferredLeaderNotAvailableException
- PrincipalDeserializationException
- Producer
- ProducerConfig
- ProducerFencedException
- ProducerInterceptor
- ProducerRecord
- ProducerState
- QuorumInfo
- QuorumInfo.ReplicaState
- Quota
- QuotaViolationException
- RangeAssignor
- Rate
- ReassignmentInProgressException
- RebalanceInProgressException
- Reconfigurable
- RecordBatchTooLargeException
- RecordDeserializationException
- RecordMetadata
- RecordsToDelete
- RecordTooLargeException
- RemoveMembersFromConsumerGroupOptions
- RemoveMembersFromConsumerGroupResult
- RenewDelegationTokenOptions
- RenewDelegationTokenResult
- ReplicaInfo
- ReplicaNotAvailableException
- Resource
- ResourceNotFoundException
- ResourcePattern
- ResourcePatternFilter
- ResourceType
- RetriableCommitFailedException
- RetriableException
- RoundRobinAssignor
- RoundRobinPartitioner
- SampledStat
- SaslAuthenticationContext
- SaslAuthenticationException
- SaslConfigs
- SaslExtensions
- SaslExtensionsCallback
- ScramCredential
- ScramCredentialCallback
- ScramCredentialInfo
- ScramExtensionsCallback
- ScramLoginModule
- ScramMechanism
- 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
- StaleMemberEpochException
- Stat
- StickyAssignor
- StreamsPartitioner
- StringDeserializer
- StringSerializer
- SupportedVersionRange
- 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
- UnacceptableCredentialException
- UniformStickyPartitioner
- UnknownLeaderEpochException
- UnknownMemberIdException
- UnknownProducerIdException
- UnknownServerException
- UnknownTopicIdException
- UnknownTopicOrPartitionException
- UnregisterBrokerOptions
- UnregisterBrokerResult
- UnreleasedInstanceIdException
- UnstableOffsetCommitException
- UnsupportedAssignorException
- UnsupportedByAuthenticationException
- UnsupportedCompressionTypeException
- UnsupportedForMessageFormatException
- UnsupportedSaslMechanismException
- UnsupportedVersionException
- UpdateFeaturesOptions
- UpdateFeaturesResult
- UserScramCredentialAlteration
- UserScramCredentialDeletion
- UserScramCredentialsDescription
- UserScramCredentialUpsertion
- Uuid
- UUIDDeserializer
- UUIDSerializer
- Value
- VoidDeserializer
- VoidSerializer
- WakeupException
- WindowedCount
- WindowedSum