All Classes

  • AbstractConfig
  • AbstractOptions
  • AccessControlEntry
  • AccessControlEntryFilter
  • AclBinding
  • AclBindingFilter
  • AclOperation
  • AclPermissionType
  • AdminClient
  • AdminClientConfig
  • AlterConfigPolicy
  • AlterConfigPolicy.RequestMetadata
  • AlterConfigsOptions
  • AlterConfigsResult
  • AlterReplicaLogDirsOptions
  • AlterReplicaLogDirsResult
  • ApiException
  • AuthenticateCallbackHandler
  • AuthenticationContext
  • AuthenticationException
  • AuthorizationException
  • BrokerNotAvailableException
  • BufferExhaustedException
  • ByteArrayDeserializer
  • ByteArraySerializer
  • ByteBufferDeserializer
  • ByteBufferSerializer
  • BytesDeserializer
  • BytesSerializer
  • Callback
  • ClientQuotaCallback
  • ClientQuotaEntity
  • ClientQuotaEntity.ConfigEntity
  • ClientQuotaEntity.ConfigEntityType
  • ClientQuotaType
  • Cluster
  • ClusterAuthorizationException
  • ClusterResource
  • ClusterResourceListener
  • CommitFailedException
  • ConcurrentTransactionsException
  • Config
  • Config
  • ConfigChangeCallback
  • ConfigData
  • ConfigDef
  • ConfigDef.CompositeValidator
  • ConfigDef.ConfigKey
  • ConfigDef.Importance
  • 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
  • ConfigException
  • ConfigProvider
  • ConfigResource
  • ConfigResource.Type
  • ConfigTransformer
  • ConfigTransformerResult
  • Configurable
  • ConfigValue
  • Consumer
  • ConsumerConfig
  • ConsumerGroupDescription
  • ConsumerGroupListing
  • ConsumerGroupState
  • ConsumerInterceptor
  • ConsumerRebalanceListener
  • ConsumerRecord
  • ConsumerRecords
  • ControllerMovedException
  • CoordinatorLoadInProgressException
  • CoordinatorNotAvailableException
  • CorruptRecordException
  • CreateAclsOptions
  • CreateAclsResult
  • CreateDelegationTokenOptions
  • CreateDelegationTokenResult
  • CreatePartitionsOptions
  • CreatePartitionsResult
  • CreateTopicPolicy
  • CreateTopicPolicy.RequestMetadata
  • CreateTopicsOptions
  • CreateTopicsResult
  • DefaultPrincipalBuilder
  • DefaultStreamsPartitioner
  • DelegationToken
  • DelegationTokenAuthorizationException
  • DelegationTokenDisabledException
  • DelegationTokenExpiredException
  • DelegationTokenNotFoundException
  • DelegationTokenOwnerMismatchException
  • DeleteAclsOptions
  • DeleteAclsResult
  • DeleteAclsResult.FilterResult
  • DeleteAclsResult.FilterResults
  • DeleteConsumerGroupsOptions
  • DeleteConsumerGroupsResult
  • DeletedRecords
  • DeleteRecordsOptions
  • DeleteRecordsResult
  • DeleteTopicsOptions
  • DeleteTopicsResult
  • DescribeAclsOptions
  • DescribeAclsResult
  • DescribeClusterOptions
  • DescribeClusterResult
  • DescribeConfigsOptions
  • DescribeConfigsResult
  • DescribeConsumerGroupsOptions
  • DescribeConsumerGroupsResult
  • DescribeDelegationTokenOptions
  • DescribeDelegationTokenResult
  • DescribeLogDirsOptions
  • DescribeLogDirsResult
  • DescribeReplicaLogDirsOptions
  • DescribeReplicaLogDirsResult
  • DescribeReplicaLogDirsResult.ReplicaLogDirInfo
  • DescribeTopicsOptions
  • DescribeTopicsResult
  • Deserializer
  • DisconnectException
  • DoubleDeserializer
  • DoubleSerializer
  • DuplicateSequenceException
  • ExpireDelegationTokenOptions
  • ExpireDelegationTokenResult
  • ExtendedDeserializer
  • ExtendedDeserializer.Wrapper
  • ExtendedSerializer
  • ExtendedSerializer.Wrapper
  • FencedLeaderEpochException
  • FetchSessionIdNotFoundException
  • FileConfigProvider
  • FloatDeserializer
  • FloatSerializer
  • GenericCoordinator
  • GroupAuthorizationException
  • GroupIdNotFoundException
  • GroupNotEmptyException
  • Header
  • Headers
  • IllegalGenerationException
  • IllegalSaslStateException
  • InconsistentGroupProtocolException
  • IntegerDeserializer
  • IntegerSerializer
  • InterfaceStability
  • InterfaceStability.Evolving
  • InterfaceStability.Stable
  • InterfaceStability.Unstable
  • InterruptException
  • InvalidCommitOffsetSizeException
  • InvalidConfigurationException
  • InvalidFetchSessionEpochException
  • InvalidFetchSizeException
  • InvalidGroupIdException
  • InvalidMetadataException
  • InvalidOffsetException
  • InvalidOffsetException
  • InvalidPartitionsException
  • InvalidPidMappingException
  • InvalidPrincipalTypeException
  • InvalidReplicaAssignmentException
  • InvalidReplicationFactorException
  • InvalidRequestException
  • InvalidRequiredAcksException
  • InvalidSessionTimeoutException
  • InvalidTimestampException
  • InvalidTopicException
  • InvalidTxnStateException
  • InvalidTxnTimeoutException
  • KafkaAdminClient
  • KafkaConsumer
  • KafkaException
  • KafkaFuture
  • KafkaFuture.BaseFunction
  • KafkaFuture.BiConsumer
  • KafkaFuture.Function
  • KafkaPrincipal
  • KafkaPrincipalBuilder
  • KafkaProducer
  • KafkaStorageException
  • LeaderNotAvailableException
  • ListConsumerGroupOffsetsOptions
  • ListConsumerGroupOffsetsResult
  • ListConsumerGroupsOptions
  • ListConsumerGroupsResult
  • ListenerNotFoundException
  • ListTopicsOptions
  • ListTopicsResult
  • LogDirNotFoundException
  • Login
  • LongDeserializer
  • LongSerializer
  • MemberAssignment
  • MemberDescription
  • Metric
  • MetricName
  • MetricNameTemplate
  • MockConsumer
  • MockProducer
  • NetworkException
  • NewPartitions
  • NewTopic
  • Node
  • NoOffsetForPartitionException
  • NotControllerException
  • NotCoordinatorException
  • NotEnoughReplicasAfterAppendException
  • NotEnoughReplicasException
  • NotLeaderForPartitionException
  • OAuthBearerExtensionsValidatorCallback
  • OAuthBearerLoginModule
  • OAuthBearerToken
  • OAuthBearerTokenCallback
  • OAuthBearerValidatorCallback
  • OffsetAndMetadata
  • OffsetAndTimestamp
  • OffsetCommitCallback
  • OffsetMetadataTooLarge
  • OffsetOutOfRangeException
  • OffsetOutOfRangeException
  • OffsetResetStrategy
  • OperationNotAttemptedException
  • OutOfOrderSequenceException
  • Partitioner
  • PartitionInfo
  • PatternType
  • PlainAuthenticateCallback
  • PlainLoginModule
  • PlaintextAuthenticationContext
  • PolicyViolationException
  • PrincipalBuilder
  • Producer
  • ProducerConfig
  • ProducerFencedException
  • ProducerInterceptor
  • ProducerRecord
  • RangeAssignor
  • ReassignmentInProgressException
  • RebalanceInProgressException
  • Reconfigurable
  • RecordBatchTooLargeException
  • RecordMetadata
  • RecordsToDelete
  • RecordTooLargeException
  • RenewDelegationTokenOptions
  • RenewDelegationTokenResult
  • ReplicaNotAvailableException
  • Resource
  • ResourceFilter
  • ResourcePattern
  • ResourcePatternFilter
  • ResourceType
  • RetriableCommitFailedException
  • RetriableException
  • RoundRobinAssignor
  • SaslAuthenticationContext
  • SaslAuthenticationException
  • SaslConfigs
  • SaslExtensions
  • SaslExtensionsCallback
  • ScramCredential
  • ScramCredentialCallback
  • ScramExtensionsCallback
  • ScramLoginModule
  • SecurityDisabledException
  • SecurityProtocol
  • Serde
  • Serdes
  • Serdes.ByteArraySerde
  • Serdes.ByteBufferSerde
  • Serdes.BytesSerde
  • Serdes.DoubleSerde
  • Serdes.FloatSerde
  • Serdes.IntegerSerde
  • Serdes.LongSerde
  • Serdes.ShortSerde
  • Serdes.StringSerde
  • Serdes.UUIDSerde
  • Serdes.WrapperSerde
  • SerializationException
  • Serializer
  • ShortDeserializer
  • ShortSerializer
  • SslAuthenticationContext
  • SslAuthenticationException
  • SslConfigs
  • StickyAssignor
  • StreamsPartitioner
  • StringDeserializer
  • StringSerializer
  • TimeoutException
  • TokenInformation
  • TopicAuthorizationException
  • TopicConfig
  • TopicDeletionDisabledException
  • TopicDescription
  • TopicExistsException
  • TopicListing
  • TopicPartition
  • TopicPartitionInfo
  • TopicPartitionReplica
  • TransactionalIdAuthorizationException
  • TransactionCoordinatorFencedException
  • UnknownLeaderEpochException
  • UnknownMemberIdException
  • UnknownProducerIdException
  • UnknownServerException
  • UnknownTopicOrPartitionException
  • UnsupportedByAuthenticationException
  • UnsupportedCompressionTypeException
  • UnsupportedForMessageFormatException
  • UnsupportedSaslMechanismException
  • UnsupportedVersionException
  • UUIDDeserializer
  • UUIDSerializer
  • WakeupException