org.apache.kafka : kafka-clients 中文文档（中英对照·API·接口·操作手册·全版本）以3.9.1为例，含Maven依赖、jar包、源码

[toc]

完整文档下载地址（类、方法、参数说明）

• kafka-clients-3.9.1.jar中文-英文对照文档.zip 下载地址：https://hanshuixin.org/resource/fileDetails?groupId=org.apache.kafka&artifactId=kafka-clients&version=3.9.1

• kafka-clients 其他版本中文文档 下载地址：https://hanshuixin.org/resource/?groupId=org.apache.kafka&artifactId=kafka-clients

  kafka-clients-3.9.1.jar中文-英文对照文档.zip 中包含以下内容

1. 中文-英文对照文档：位于压缩包内的“文档”文件夹中
2. 说明文件：使用说明.txt、README.md
3. Maven依赖：kafka-clients-3.9.1.jar Maven依赖信息(可用于项目pom.xml).txt
4. Gradle依赖：kafka-clients-3.9.1.jar Gradle依赖信息(可用于项目build.gradle).txt
5. jar包下载地址：kafka-clients-3.9.1.jar下载地址(官方地址+国内镜像地址).txt
6. 源码下载地址：kafka-clients-3.9.1-sources.jar下载地址(官方地址+国内镜像地址).txt

使用方法

1. 解压 kafka-clients-3.9.1.jar中文-英文对照文档.zip，找到 解压后的文件夹>文档>index.html，双击index.html即可用浏览器打开查看。
2. 为了防止解压后路径太长导致浏览器无法打开，推荐在解压时选择“解压到当前文件夹”（放心，自带文件夹，文件不会散落一地）。
3. 有时，一套Java组件会有多个jar，所以在下载前，请仔细阅读本篇描述，以确保这就是你需要的文件。

组件信息

简介

• 名称： Apache Kafka
• 描述： org.apache.kafka - kafka-clients
• 版本： 3.9.1

Maven依赖

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka-clients</artifactId>
	<version>3.9.1</version>
</dependency> 

Gradle依赖

Gradle:
	implementation group: 'org.apache.kafka', name: 'kafka-clients', version: '3.9.1'
Gradle (Short):
	implementation 'org.apache.kafka:kafka-clients:3.9.1'
Gradle (Kotlin):
	implementation("org.apache.kafka:kafka-clients:3.9.1") 

寒水馨 Java 组件中文文档系列说明

• 文档为 Java 组件的中文翻译文档
• 文档由 寒水馨 翻译整理，非官方版本
• 本系列文档获取地址：https://hanshuixin.org
• 本文档为人性化翻译，精心制作，请放心使用
• 本文档为双语同时展示，一行原文、一行译文，可逐行对照，避免了原文/译文来回切换的麻烦
• 有原文可参照，不再担心翻译偏差误导
• 边学技术、边学英语
• 只翻译了该翻译的内容，如：注释、说明、描述、用法讲解 等
• 不该翻译的内容保持原样，如：类名、方法名、包名、类型、关键字、代码 等

版权声明与来源信息

本翻译文档基于以下开源项目制作，严格遵守各项目的开源许可证，并在此列出其版权归属与许可证信息。

• 组件 GAV 坐标：org.apache.kafka:kafka-clients:3.9.1
• 原始项目地址：https://central.sonatype.com/artifact/org.apache.kafka/kafka-clients/3.9.1
• 许可证：The Apache License, Version 2.0
• 许可证链接：http://www.apache.org/licenses/LICENSE-2.0.txt
• 所有原始代码及注释版权归其原作者所有
• 本翻译内容的版权归 寒水馨 所有（© 2025 寒水馨），未经许可不得用于二次分发或再销售

本组件包含的 Java package（包）

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 

本组件包含的 Java class（类）

org.apache.kafka.clients.admin.AbortTransactionOptions
org.apache.kafka.clients.admin.AbortTransactionResult
org.apache.kafka.clients.admin.AbortTransactionSpec
org.apache.kafka.clients.admin.AbstractOptions
org.apache.kafka.clients.admin.AddRaftVoterOptions
org.apache.kafka.clients.admin.AddRaftVoterResult
org.apache.kafka.clients.admin.Admin
org.apache.kafka.clients.admin.AdminClient
org.apache.kafka.clients.admin.AdminClientConfig
org.apache.kafka.clients.admin.AlterClientQuotasOptions
org.apache.kafka.clients.admin.AlterClientQuotasResult
org.apache.kafka.clients.admin.AlterConfigOp
org.apache.kafka.clients.admin.AlterConfigOp.OpType
org.apache.kafka.clients.admin.AlterConfigsOptions
org.apache.kafka.clients.admin.AlterConfigsResult
org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions
org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult
org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions
org.apache.kafka.clients.admin.AlterPartitionReassignmentsResult
org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions
org.apache.kafka.clients.admin.AlterReplicaLogDirsResult
org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions
org.apache.kafka.clients.admin.AlterUserScramCredentialsResult
org.apache.kafka.clients.admin.ClientMetricsResourceListing
org.apache.kafka.clients.admin.Config
org.apache.kafka.clients.admin.ConfigEntry
org.apache.kafka.clients.admin.ConfigEntry.ConfigSource
org.apache.kafka.clients.admin.ConfigEntry.ConfigSynonym
org.apache.kafka.clients.admin.ConfigEntry.ConfigType
org.apache.kafka.clients.admin.ConsumerGroupDescription
org.apache.kafka.clients.admin.ConsumerGroupListing
org.apache.kafka.clients.admin.CreateAclsOptions
org.apache.kafka.clients.admin.CreateAclsResult
org.apache.kafka.clients.admin.CreateDelegationTokenOptions
org.apache.kafka.clients.admin.CreateDelegationTokenResult
org.apache.kafka.clients.admin.CreatePartitionsOptions
org.apache.kafka.clients.admin.CreatePartitionsResult
org.apache.kafka.clients.admin.CreateTopicsOptions
org.apache.kafka.clients.admin.CreateTopicsResult
org.apache.kafka.clients.admin.CreateTopicsResult.TopicMetadataAndConfig
org.apache.kafka.clients.admin.DeleteAclsOptions
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.DeleteConsumerGroupOffsetsOptions
org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsResult
org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions
org.apache.kafka.clients.admin.DeleteConsumerGroupsResult
org.apache.kafka.clients.admin.DeleteRecordsOptions
org.apache.kafka.clients.admin.DeleteRecordsResult
org.apache.kafka.clients.admin.DeleteTopicsOptions
org.apache.kafka.clients.admin.DeleteTopicsResult
org.apache.kafka.clients.admin.DeletedRecords
org.apache.kafka.clients.admin.DescribeAclsOptions
org.apache.kafka.clients.admin.DescribeAclsResult
org.apache.kafka.clients.admin.DescribeClientQuotasOptions
org.apache.kafka.clients.admin.DescribeClientQuotasResult
org.apache.kafka.clients.admin.DescribeClusterOptions
org.apache.kafka.clients.admin.DescribeClusterResult
org.apache.kafka.clients.admin.DescribeConfigsOptions
org.apache.kafka.clients.admin.DescribeConfigsResult
org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions
org.apache.kafka.clients.admin.DescribeConsumerGroupsResult
org.apache.kafka.clients.admin.DescribeDelegationTokenOptions
org.apache.kafka.clients.admin.DescribeDelegationTokenResult
org.apache.kafka.clients.admin.DescribeFeaturesOptions
org.apache.kafka.clients.admin.DescribeFeaturesResult
org.apache.kafka.clients.admin.DescribeLogDirsOptions
org.apache.kafka.clients.admin.DescribeLogDirsResult
org.apache.kafka.clients.admin.DescribeMetadataQuorumOptions
org.apache.kafka.clients.admin.DescribeMetadataQuorumResult
org.apache.kafka.clients.admin.DescribeProducersOptions
org.apache.kafka.clients.admin.DescribeProducersResult
org.apache.kafka.clients.admin.DescribeProducersResult.PartitionProducerState
org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions
org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult
org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo
org.apache.kafka.clients.admin.DescribeTopicsOptions
org.apache.kafka.clients.admin.DescribeTopicsResult
org.apache.kafka.clients.admin.DescribeTransactionsOptions
org.apache.kafka.clients.admin.DescribeTransactionsResult
org.apache.kafka.clients.admin.DescribeUserScramCredentialsOptions
org.apache.kafka.clients.admin.DescribeUserScramCredentialsResult
org.apache.kafka.clients.admin.ElectLeadersOptions
org.apache.kafka.clients.admin.ElectLeadersResult
org.apache.kafka.clients.admin.EndpointType
org.apache.kafka.clients.admin.ExpireDelegationTokenOptions
org.apache.kafka.clients.admin.ExpireDelegationTokenResult
org.apache.kafka.clients.admin.FeatureMetadata
org.apache.kafka.clients.admin.FeatureUpdate
org.apache.kafka.clients.admin.FeatureUpdate.UpgradeType
org.apache.kafka.clients.admin.FenceProducersOptions
org.apache.kafka.clients.admin.FenceProducersResult
org.apache.kafka.clients.admin.FinalizedVersionRange
org.apache.kafka.clients.admin.ForwardingAdmin
org.apache.kafka.clients.admin.KafkaAdminClient
org.apache.kafka.clients.admin.ListClientMetricsResourcesOptions
org.apache.kafka.clients.admin.ListClientMetricsResourcesResult
org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions
org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult
org.apache.kafka.clients.admin.ListConsumerGroupOffsetsSpec
org.apache.kafka.clients.admin.ListConsumerGroupsOptions
org.apache.kafka.clients.admin.ListConsumerGroupsResult
org.apache.kafka.clients.admin.ListOffsetsOptions
org.apache.kafka.clients.admin.ListOffsetsResult
org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo
org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions
org.apache.kafka.clients.admin.ListPartitionReassignmentsResult
org.apache.kafka.clients.admin.ListTopicsOptions
org.apache.kafka.clients.admin.ListTopicsResult
org.apache.kafka.clients.admin.ListTransactionsOptions
org.apache.kafka.clients.admin.ListTransactionsResult
org.apache.kafka.clients.admin.LogDirDescription
org.apache.kafka.clients.admin.MemberAssignment
org.apache.kafka.clients.admin.MemberDescription
org.apache.kafka.clients.admin.MemberToRemove
org.apache.kafka.clients.admin.NewPartitionReassignment
org.apache.kafka.clients.admin.NewPartitions
org.apache.kafka.clients.admin.NewTopic
org.apache.kafka.clients.admin.OffsetSpec
org.apache.kafka.clients.admin.OffsetSpec.EarliestLocalSpec
org.apache.kafka.clients.admin.OffsetSpec.EarliestSpec
org.apache.kafka.clients.admin.OffsetSpec.LatestSpec
org.apache.kafka.clients.admin.OffsetSpec.LatestTieredSpec
org.apache.kafka.clients.admin.OffsetSpec.MaxTimestampSpec
org.apache.kafka.clients.admin.OffsetSpec.TimestampSpec
org.apache.kafka.clients.admin.PartitionReassignment
org.apache.kafka.clients.admin.ProducerState
org.apache.kafka.clients.admin.QuorumInfo
org.apache.kafka.clients.admin.QuorumInfo.Node
org.apache.kafka.clients.admin.QuorumInfo.ReplicaState
org.apache.kafka.clients.admin.RaftVoterEndpoint
org.apache.kafka.clients.admin.RecordsToDelete
org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions
org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult
org.apache.kafka.clients.admin.RemoveRaftVoterOptions
org.apache.kafka.clients.admin.RemoveRaftVoterResult
org.apache.kafka.clients.admin.RenewDelegationTokenOptions
org.apache.kafka.clients.admin.RenewDelegationTokenResult
org.apache.kafka.clients.admin.ReplicaInfo
org.apache.kafka.clients.admin.ScramCredentialInfo
org.apache.kafka.clients.admin.ScramMechanism
org.apache.kafka.clients.admin.SupportedVersionRange
org.apache.kafka.clients.admin.TopicDescription
org.apache.kafka.clients.admin.TopicListing
org.apache.kafka.clients.admin.TransactionDescription
org.apache.kafka.clients.admin.TransactionListing
org.apache.kafka.clients.admin.TransactionState
org.apache.kafka.clients.admin.UnregisterBrokerOptions
org.apache.kafka.clients.admin.UnregisterBrokerResult
org.apache.kafka.clients.admin.UpdateFeaturesOptions
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.clients.consumer.AcknowledgeType
org.apache.kafka.clients.consumer.AcknowledgementCommitCallback
org.apache.kafka.clients.consumer.CommitFailedException
org.apache.kafka.clients.consumer.Consumer
org.apache.kafka.clients.consumer.ConsumerConfig
org.apache.kafka.clients.consumer.ConsumerGroupMetadata
org.apache.kafka.clients.consumer.ConsumerInterceptor
org.apache.kafka.clients.consumer.ConsumerPartitionAssignor
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.RebalanceProtocol
org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Subscription
org.apache.kafka.clients.consumer.ConsumerRebalanceListener
org.apache.kafka.clients.consumer.ConsumerRecord
org.apache.kafka.clients.consumer.ConsumerRecords
org.apache.kafka.clients.consumer.CooperativeStickyAssignor
org.apache.kafka.clients.consumer.GroupProtocol
org.apache.kafka.clients.consumer.InvalidOffsetException
org.apache.kafka.clients.consumer.KafkaConsumer
org.apache.kafka.clients.consumer.KafkaShareConsumer
org.apache.kafka.clients.consumer.LogTruncationException
org.apache.kafka.clients.consumer.MockConsumer
org.apache.kafka.clients.consumer.MockShareConsumer
org.apache.kafka.clients.consumer.NoOffsetForPartitionException
org.apache.kafka.clients.consumer.OffsetAndMetadata
org.apache.kafka.clients.consumer.OffsetAndTimestamp
org.apache.kafka.clients.consumer.OffsetCommitCallback
org.apache.kafka.clients.consumer.OffsetOutOfRangeException
org.apache.kafka.clients.consumer.OffsetResetStrategy
org.apache.kafka.clients.consumer.RangeAssignor
org.apache.kafka.clients.consumer.RetriableCommitFailedException
org.apache.kafka.clients.consumer.RoundRobinAssignor
org.apache.kafka.clients.consumer.ShareConsumer
org.apache.kafka.clients.consumer.StickyAssignor
org.apache.kafka.clients.producer.BufferExhaustedException
org.apache.kafka.clients.producer.Callback
org.apache.kafka.clients.producer.KafkaProducer
org.apache.kafka.clients.producer.MockProducer
org.apache.kafka.clients.producer.Partitioner
org.apache.kafka.clients.producer.Producer
org.apache.kafka.clients.producer.ProducerConfig
org.apache.kafka.clients.producer.ProducerInterceptor
org.apache.kafka.clients.producer.ProducerRecord
org.apache.kafka.clients.producer.RecordMetadata
org.apache.kafka.clients.producer.RoundRobinPartitioner
org.apache.kafka.clients.producer.UniformStickyPartitioner
org.apache.kafka.common.Cluster
org.apache.kafka.common.ClusterResource
org.apache.kafka.common.ClusterResourceListener
org.apache.kafka.common.Configurable
org.apache.kafka.common.ConsumerGroupState
org.apache.kafka.common.ElectionType
org.apache.kafka.common.Endpoint
org.apache.kafka.common.GroupType
org.apache.kafka.common.InvalidRecordException
org.apache.kafka.common.IsolationLevel
org.apache.kafka.common.KafkaException
org.apache.kafka.common.KafkaFuture
org.apache.kafka.common.KafkaFuture.BaseFunction
org.apache.kafka.common.KafkaFuture.BiConsumer
org.apache.kafka.common.KafkaFuture.Function
org.apache.kafka.common.MessageFormatter
org.apache.kafka.common.Metric
org.apache.kafka.common.MetricName
org.apache.kafka.common.MetricNameTemplate
org.apache.kafka.common.Node
org.apache.kafka.common.PartitionInfo
org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.ShareGroupState
org.apache.kafka.common.TopicCollection
org.apache.kafka.common.TopicCollection.TopicIdCollection
org.apache.kafka.common.TopicCollection.TopicNameCollection
org.apache.kafka.common.TopicIdPartition
org.apache.kafka.common.TopicPartition
org.apache.kafka.common.TopicPartitionInfo
org.apache.kafka.common.TopicPartitionReplica
org.apache.kafka.common.Uuid
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.common.acl.AclOperation
org.apache.kafka.common.acl.AclPermissionType
org.apache.kafka.common.annotation.InterfaceStability
org.apache.kafka.common.annotation.InterfaceStability.Evolving
org.apache.kafka.common.annotation.InterfaceStability.Stable
org.apache.kafka.common.annotation.InterfaceStability.Unstable
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.common.config.Config
org.apache.kafka.common.config.ConfigChangeCallback
org.apache.kafka.common.config.ConfigData
org.apache.kafka.common.config.ConfigDef
org.apache.kafka.common.config.ConfigDef.CaseInsensitiveValidString
org.apache.kafka.common.config.ConfigDef.CompositeValidator
org.apache.kafka.common.config.ConfigDef.ConfigKey
org.apache.kafka.common.config.ConfigDef.Importance
org.apache.kafka.common.config.ConfigDef.LambdaValidator
org.apache.kafka.common.config.ConfigDef.ListSize
org.apache.kafka.common.config.ConfigDef.NonEmptyString
org.apache.kafka.common.config.ConfigDef.NonEmptyStringWithoutControlChars
org.apache.kafka.common.config.ConfigDef.NonNullValidator
org.apache.kafka.common.config.ConfigDef.Range
org.apache.kafka.common.config.ConfigDef.Recommender
org.apache.kafka.common.config.ConfigDef.Type
org.apache.kafka.common.config.ConfigDef.ValidList
org.apache.kafka.common.config.ConfigDef.ValidString
org.apache.kafka.common.config.ConfigDef.Validator
org.apache.kafka.common.config.ConfigDef.Width
org.apache.kafka.common.config.ConfigException
org.apache.kafka.common.config.ConfigResource
org.apache.kafka.common.config.ConfigResource.Type
org.apache.kafka.common.config.ConfigTransformer
org.apache.kafka.common.config.ConfigTransformerResult
org.apache.kafka.common.config.ConfigValue
org.apache.kafka.common.config.LogLevelConfig
org.apache.kafka.common.config.SaslConfigs
org.apache.kafka.common.config.SecurityConfig
org.apache.kafka.common.config.SslClientAuth
org.apache.kafka.common.config.SslConfigs
org.apache.kafka.common.config.TopicConfig
org.apache.kafka.common.config.provider.ConfigProvider
org.apache.kafka.common.config.provider.DirectoryConfigProvider
org.apache.kafka.common.config.provider.EnvVarConfigProvider
org.apache.kafka.common.config.provider.FileConfigProvider
org.apache.kafka.common.errors.ApiException
org.apache.kafka.common.errors.AuthenticationException
org.apache.kafka.common.errors.AuthorizationException
org.apache.kafka.common.errors.AuthorizerNotReadyException
org.apache.kafka.common.errors.BrokerIdNotRegisteredException
org.apache.kafka.common.errors.BrokerNotAvailableException
org.apache.kafka.common.errors.ClusterAuthorizationException
org.apache.kafka.common.errors.ConcurrentTransactionsException
org.apache.kafka.common.errors.ControllerMovedException
org.apache.kafka.common.errors.CoordinatorLoadInProgressException
org.apache.kafka.common.errors.CoordinatorNotAvailableException
org.apache.kafka.common.errors.CorruptRecordException
org.apache.kafka.common.errors.DelegationTokenAuthorizationException
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.DisconnectException
org.apache.kafka.common.errors.DuplicateBrokerRegistrationException
org.apache.kafka.common.errors.DuplicateResourceException
org.apache.kafka.common.errors.DuplicateSequenceException
org.apache.kafka.common.errors.DuplicateVoterException
org.apache.kafka.common.errors.ElectionNotNeededException
org.apache.kafka.common.errors.EligibleLeadersNotAvailableException
org.apache.kafka.common.errors.FeatureUpdateFailedException
org.apache.kafka.common.errors.FencedInstanceIdException
org.apache.kafka.common.errors.FencedLeaderEpochException
org.apache.kafka.common.errors.FencedMemberEpochException
org.apache.kafka.common.errors.FencedStateEpochException
org.apache.kafka.common.errors.FetchSessionIdNotFoundException
org.apache.kafka.common.errors.FetchSessionTopicIdException
org.apache.kafka.common.errors.GroupAuthorizationException
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.IllegalSaslStateException
org.apache.kafka.common.errors.InconsistentClusterIdException
org.apache.kafka.common.errors.InconsistentGroupProtocolException
org.apache.kafka.common.errors.InconsistentTopicIdException
org.apache.kafka.common.errors.InconsistentVoterSetException
org.apache.kafka.common.errors.IneligibleReplicaException
org.apache.kafka.common.errors.InterruptException
org.apache.kafka.common.errors.InvalidCommitOffsetSizeException
org.apache.kafka.common.errors.InvalidConfigurationException
org.apache.kafka.common.errors.InvalidFetchSessionEpochException
org.apache.kafka.common.errors.InvalidFetchSizeException
org.apache.kafka.common.errors.InvalidGroupIdException
org.apache.kafka.common.errors.InvalidMetadataException
org.apache.kafka.common.errors.InvalidOffsetException
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.errors.InvalidRecordStateException
org.apache.kafka.common.errors.InvalidRegistrationException
org.apache.kafka.common.errors.InvalidReplicaAssignmentException
org.apache.kafka.common.errors.InvalidReplicationFactorException
org.apache.kafka.common.errors.InvalidRequestException
org.apache.kafka.common.errors.InvalidRequiredAcksException
org.apache.kafka.common.errors.InvalidSessionTimeoutException
org.apache.kafka.common.errors.InvalidShareSessionEpochException
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.InvalidVoterKeyException
org.apache.kafka.common.errors.KafkaStorageException
org.apache.kafka.common.errors.LeaderNotAvailableException
org.apache.kafka.common.errors.ListenerNotFoundException
org.apache.kafka.common.errors.LogDirNotFoundException
org.apache.kafka.common.errors.MemberIdRequiredException
org.apache.kafka.common.errors.MismatchedEndpointTypeException
org.apache.kafka.common.errors.NetworkException
org.apache.kafka.common.errors.NewLeaderElectedException
org.apache.kafka.common.errors.NoReassignmentInProgressException
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.NotLeaderForPartitionException
org.apache.kafka.common.errors.NotLeaderOrFollowerException
org.apache.kafka.common.errors.OffsetMetadataTooLarge
org.apache.kafka.common.errors.OffsetMovedToTieredStorageException
org.apache.kafka.common.errors.OffsetNotAvailableException
org.apache.kafka.common.errors.OffsetOutOfRangeException
org.apache.kafka.common.errors.OperationNotAttemptedException
org.apache.kafka.common.errors.OutOfOrderSequenceException
org.apache.kafka.common.errors.PolicyViolationException
org.apache.kafka.common.errors.PositionOutOfRangeException
org.apache.kafka.common.errors.PreferredLeaderNotAvailableException
org.apache.kafka.common.errors.PrincipalDeserializationException
org.apache.kafka.common.errors.ProducerFencedException
org.apache.kafka.common.errors.ReassignmentInProgressException
org.apache.kafka.common.errors.RebalanceInProgressException
org.apache.kafka.common.errors.RecordBatchTooLargeException
org.apache.kafka.common.errors.RecordDeserializationException
org.apache.kafka.common.errors.RecordDeserializationException.DeserializationExceptionOrigin
org.apache.kafka.common.errors.RecordTooLargeException
org.apache.kafka.common.errors.ReplicaNotAvailableException
org.apache.kafka.common.errors.ResourceNotFoundException
org.apache.kafka.common.errors.RetriableException
org.apache.kafka.common.errors.SaslAuthenticationException
org.apache.kafka.common.errors.SecurityDisabledException
org.apache.kafka.common.errors.SerializationException
org.apache.kafka.common.errors.ShareSessionNotFoundException
org.apache.kafka.common.errors.SnapshotNotFoundException
org.apache.kafka.common.errors.SslAuthenticationException
org.apache.kafka.common.errors.StaleBrokerEpochException
org.apache.kafka.common.errors.StaleMemberEpochException
org.apache.kafka.common.errors.TelemetryTooLargeException
org.apache.kafka.common.errors.ThrottlingQuotaExceededException
org.apache.kafka.common.errors.TimeoutException
org.apache.kafka.common.errors.TopicAuthorizationException
org.apache.kafka.common.errors.TopicDeletionDisabledException
org.apache.kafka.common.errors.TopicExistsException
org.apache.kafka.common.errors.TransactionAbortableException
org.apache.kafka.common.errors.TransactionAbortedException
org.apache.kafka.common.errors.TransactionCoordinatorFencedException
org.apache.kafka.common.errors.TransactionalIdAuthorizationException
org.apache.kafka.common.errors.TransactionalIdNotFoundException
org.apache.kafka.common.errors.UnacceptableCredentialException
org.apache.kafka.common.errors.UnknownControllerIdException
org.apache.kafka.common.errors.UnknownLeaderEpochException
org.apache.kafka.common.errors.UnknownMemberIdException
org.apache.kafka.common.errors.UnknownProducerIdException
org.apache.kafka.common.errors.UnknownServerException
org.apache.kafka.common.errors.UnknownSubscriptionIdException
org.apache.kafka.common.errors.UnknownTopicIdException
org.apache.kafka.common.errors.UnknownTopicOrPartitionException
org.apache.kafka.common.errors.UnreleasedInstanceIdException
org.apache.kafka.common.errors.UnstableOffsetCommitException
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.UnsupportedSaslMechanismException
org.apache.kafka.common.errors.UnsupportedVersionException
org.apache.kafka.common.errors.VoterNotFoundException
org.apache.kafka.common.errors.WakeupException
org.apache.kafka.common.header.Header
org.apache.kafka.common.header.Headers
org.apache.kafka.common.metrics.CompoundStat
org.apache.kafka.common.metrics.CompoundStat.NamedMeasurable
org.apache.kafka.common.metrics.Gauge
org.apache.kafka.common.metrics.JmxReporter
org.apache.kafka.common.metrics.KafkaMetric
org.apache.kafka.common.metrics.KafkaMetricsContext
org.apache.kafka.common.metrics.Measurable
org.apache.kafka.common.metrics.MeasurableStat
org.apache.kafka.common.metrics.MetricConfig
org.apache.kafka.common.metrics.MetricValueProvider
org.apache.kafka.common.metrics.Metrics
org.apache.kafka.common.metrics.MetricsContext
org.apache.kafka.common.metrics.MetricsReporter
org.apache.kafka.common.metrics.Quota
org.apache.kafka.common.metrics.QuotaViolationException
org.apache.kafka.common.metrics.Sensor
org.apache.kafka.common.metrics.Sensor.RecordingLevel
org.apache.kafka.common.metrics.Stat
org.apache.kafka.common.metrics.stats.Avg
org.apache.kafka.common.metrics.stats.CumulativeCount
org.apache.kafka.common.metrics.stats.CumulativeSum
org.apache.kafka.common.metrics.stats.Frequencies
org.apache.kafka.common.metrics.stats.Frequency
org.apache.kafka.common.metrics.stats.Histogram
org.apache.kafka.common.metrics.stats.Histogram.BinScheme
org.apache.kafka.common.metrics.stats.Histogram.ConstantBinScheme
org.apache.kafka.common.metrics.stats.Histogram.LinearBinScheme
org.apache.kafka.common.metrics.stats.Max
org.apache.kafka.common.metrics.stats.Meter
org.apache.kafka.common.metrics.stats.Min
org.apache.kafka.common.metrics.stats.Percentile
org.apache.kafka.common.metrics.stats.Percentiles
org.apache.kafka.common.metrics.stats.Percentiles.BucketSizing
org.apache.kafka.common.metrics.stats.Rate
org.apache.kafka.common.metrics.stats.SampledStat
org.apache.kafka.common.metrics.stats.SimpleRate
org.apache.kafka.common.metrics.stats.TokenBucket
org.apache.kafka.common.metrics.stats.Value
org.apache.kafka.common.metrics.stats.WindowedCount
org.apache.kafka.common.metrics.stats.WindowedSum
org.apache.kafka.common.quota.ClientQuotaAlteration
org.apache.kafka.common.quota.ClientQuotaAlteration.Op
org.apache.kafka.common.quota.ClientQuotaEntity
org.apache.kafka.common.quota.ClientQuotaFilter
org.apache.kafka.common.quota.ClientQuotaFilterComponent
org.apache.kafka.common.resource.PatternType
org.apache.kafka.common.resource.Resource
org.apache.kafka.common.resource.ResourcePattern
org.apache.kafka.common.resource.ResourcePatternFilter
org.apache.kafka.common.resource.ResourceType
org.apache.kafka.common.security.auth.AuthenticateCallbackHandler
org.apache.kafka.common.security.auth.AuthenticationContext
org.apache.kafka.common.security.auth.KafkaPrincipal
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.security.auth.PlaintextAuthenticationContext
org.apache.kafka.common.security.auth.SaslAuthenticationContext
org.apache.kafka.common.security.auth.SaslExtensions
org.apache.kafka.common.security.auth.SaslExtensionsCallback
org.apache.kafka.common.security.auth.SecurityProtocol
org.apache.kafka.common.security.auth.SecurityProviderCreator
org.apache.kafka.common.security.auth.SslAuthenticationContext
org.apache.kafka.common.security.auth.SslEngineFactory
org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback
org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler
org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule
org.apache.kafka.common.security.oauthbearer.OAuthBearerToken
org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback
org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback
org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler
org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler
org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler
org.apache.kafka.common.security.plain.PlainAuthenticateCallback
org.apache.kafka.common.security.plain.PlainLoginModule
org.apache.kafka.common.security.scram.ScramCredential
org.apache.kafka.common.security.scram.ScramCredentialCallback
org.apache.kafka.common.security.scram.ScramExtensionsCallback
org.apache.kafka.common.security.scram.ScramLoginModule
org.apache.kafka.common.security.token.delegation.DelegationToken
org.apache.kafka.common.security.token.delegation.TokenInformation
org.apache.kafka.common.serialization.BooleanDeserializer
org.apache.kafka.common.serialization.BooleanSerializer
org.apache.kafka.common.serialization.ByteArrayDeserializer
org.apache.kafka.common.serialization.ByteArraySerializer
org.apache.kafka.common.serialization.ByteBufferDeserializer
org.apache.kafka.common.serialization.ByteBufferSerializer
org.apache.kafka.common.serialization.BytesDeserializer
org.apache.kafka.common.serialization.BytesSerializer
org.apache.kafka.common.serialization.Deserializer
org.apache.kafka.common.serialization.DoubleDeserializer
org.apache.kafka.common.serialization.DoubleSerializer
org.apache.kafka.common.serialization.FloatDeserializer
org.apache.kafka.common.serialization.FloatSerializer
org.apache.kafka.common.serialization.IntegerDeserializer
org.apache.kafka.common.serialization.IntegerSerializer
org.apache.kafka.common.serialization.ListDeserializer
org.apache.kafka.common.serialization.ListSerializer
org.apache.kafka.common.serialization.LongDeserializer
org.apache.kafka.common.serialization.LongSerializer
org.apache.kafka.common.serialization.Serde
org.apache.kafka.common.serialization.Serdes
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
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.Serdes.WrapperSerde
org.apache.kafka.common.serialization.Serializer
org.apache.kafka.common.serialization.ShortDeserializer
org.apache.kafka.common.serialization.ShortSerializer
org.apache.kafka.common.serialization.StringDeserializer
org.apache.kafka.common.serialization.StringSerializer
org.apache.kafka.common.serialization.UUIDDeserializer
org.apache.kafka.common.serialization.UUIDSerializer
org.apache.kafka.common.serialization.VoidDeserializer
org.apache.kafka.common.serialization.VoidSerializer
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.server.authorizer.AuthorizableRequestContext
org.apache.kafka.server.authorizer.AuthorizationResult
org.apache.kafka.server.authorizer.Authorizer
org.apache.kafka.server.authorizer.AuthorizerServerInfo
org.apache.kafka.server.policy.AlterConfigPolicy
org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata
org.apache.kafka.server.policy.CreateTopicPolicy
org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata
org.apache.kafka.server.quota.ClientQuotaCallback
org.apache.kafka.server.quota.ClientQuotaEntity
org.apache.kafka.server.quota.ClientQuotaEntity.ConfigEntity
org.apache.kafka.server.quota.ClientQuotaEntity.ConfigEntityType
org.apache.kafka.server.quota.ClientQuotaType
org.apache.kafka.server.telemetry.ClientTelemetry
org.apache.kafka.server.telemetry.ClientTelemetryPayload
org.apache.kafka.server.telemetry.ClientTelemetryReceiver 

完整文档下载地址（类、方法、参数说明）

• kafka-clients-3.9.1.jar中文-英文对照文档.zip 下载地址：https://hanshuixin.org/resource/fileDetails?groupId=org.apache.kafka&artifactId=kafka-clients&version=3.9.1
• kafka-clients 其他版本中文文档 下载地址：https://hanshuixin.org/resource/?groupId=org.apache.kafka&artifactId=kafka-clients