Path	Lines of Code
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java	35
clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java	17
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java	77
clients/src/main/java/org/apache/kafka/clients/ClientResponse.java	109
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java	224
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java	302
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java	242
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java	10
clients/src/main/java/org/apache/kafka/clients/DefaultHostResolver.java	9
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java	406
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java	69
clients/src/main/java/org/apache/kafka/clients/HostResolver.java	6
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java	96
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java	35
clients/src/main/java/org/apache/kafka/clients/LeastLoadedNode.java	16
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java	45
clients/src/main/java/org/apache/kafka/clients/Metadata.java	525
clients/src/main/java/org/apache/kafka/clients/MetadataRecoveryStrategy.java	20
clients/src/main/java/org/apache/kafka/clients/MetadataSnapshot.java	178
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java	24
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java	1124
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java	74
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java	170
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java	4
clients/src/main/java/org/apache/kafka/clients/StaleMetadataException.java	9
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionOptions.java	9
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionSpec.java	55
clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/AddRaftVoterOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/AddRaftVoterResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java	351
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java	11
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java	224
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasResult.java	17
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java	59
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java	16
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java	49
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java	24
clients/src/main/java/org/apache/kafka/clients/admin/AlterShareGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterShareGroupOffsetsResult.java	51
clients/src/main/java/org/apache/kafka/clients/admin/AlterStreamsGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterStreamsGroupOffsetsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/ClassicGroupDescription.java	93
clients/src/main/java/org/apache/kafka/clients/admin/ClientMetricsResourceListing.java	28
clients/src/main/java/org/apache/kafka/clients/admin/Config.java	36
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java	167
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java	154
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java	86
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java	8
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java	17
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java	40
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenResult.java	12
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java	22
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java	15
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java	74
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java	8
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java	62
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java	57
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java	19
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupOffsetsResult.java	62
clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java	21
clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupOffsetsResult.java	23
clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupsResult.java	21
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java	16
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java	34
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java	8
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClassicGroupsOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClassicGroupsResult.java	31
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasResult.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java	23
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java	33
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java	30
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java	29
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesOptions.java	3
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesResult.java	11
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java	29
clients/src/main/java/org/apache/kafka/clients/admin/DescribeMetadataQuorumOptions.java	3
clients/src/main/java/org/apache/kafka/clients/admin/DescribeMetadataQuorumResult.java	11
clients/src/main/java/org/apache/kafka/clients/admin/DescribeProducersOptions.java	33
clients/src/main/java/org/apache/kafka/clients/admin/DescribeProducersResult.java	51
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java	77
clients/src/main/java/org/apache/kafka/clients/admin/DescribeShareGroupsOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeShareGroupsResult.java	31
clients/src/main/java/org/apache/kafka/clients/admin/DescribeStreamsGroupsOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeStreamsGroupsResult.java	31
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java	54
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTransactionsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTransactionsResult.java	36
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions.java	4
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java	81
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersOptions.java	5
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/EndpointType.java	22
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenResult.java	11
clients/src/main/java/org/apache/kafka/clients/admin/FeatureMetadata.java	62
clients/src/main/java/org/apache/kafka/clients/admin/FeatureUpdate.java	67
clients/src/main/java/org/apache/kafka/clients/admin/FenceProducersOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/FenceProducersResult.java	37
clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java	46
clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java	285
clients/src/main/java/org/apache/kafka/clients/admin/GroupListing.java	57
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java	4131
clients/src/main/java/org/apache/kafka/clients/admin/ListClientMetricsResourcesOptions.java	3
clients/src/main/java/org/apache/kafka/clients/admin/ListClientMetricsResourcesResult.java	21
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java	11
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java	43
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsSpec.java	35
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java	39
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java	45
clients/src/main/java/org/apache/kafka/clients/admin/ListGroupsOptions.java	38
clients/src/main/java/org/apache/kafka/clients/admin/ListGroupsResult.java	49
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsOptions.java	15
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsResult.java	59
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsOptions.java	3
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java	38
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsSpec.java	38
clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsResult.java	23
clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsSpec.java	15
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java	33
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java	20
clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsOptions.java	64
clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsResult.java	64
clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java	43
clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java	30
clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java	133
clients/src/main/java/org/apache/kafka/clients/admin/MemberToRemove.java	31
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitionReassignment.java	14
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java	27
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java	100
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java	36
clients/src/main/java/org/apache/kafka/clients/admin/PartitionReassignment.java	30
clients/src/main/java/org/apache/kafka/clients/admin/ProducerState.java	73
clients/src/main/java/org/apache/kafka/clients/admin/QuorumInfo.java	169
clients/src/main/java/org/apache/kafka/clients/admin/RaftVoterEndpoint.java	64
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java	29
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java	30
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java	77
clients/src/main/java/org/apache/kafka/clients/admin/RemoveRaftVoterOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/RemoveRaftVoterResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenOptions.java	11
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenResult.java	11
clients/src/main/java/org/apache/kafka/clients/admin/ReplicaInfo.java	28
clients/src/main/java/org/apache/kafka/clients/admin/ScramCredentialInfo.java	35
clients/src/main/java/org/apache/kafka/clients/admin/ScramMechanism.java	34
clients/src/main/java/org/apache/kafka/clients/admin/ShareGroupDescription.java	93
clients/src/main/java/org/apache/kafka/clients/admin/ShareMemberAssignment.java	32
clients/src/main/java/org/apache/kafka/clients/admin/ShareMemberDescription.java	65
clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupDescription.java	116
clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupMemberAssignment.java	95
clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupMemberDescription.java	252
clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupSubtopologyDescription.java	126
clients/src/main/java/org/apache/kafka/clients/admin/SupportedVersionRange.java	42
clients/src/main/java/org/apache/kafka/clients/admin/TerminateTransactionOptions.java	9
clients/src/main/java/org/apache/kafka/clients/admin/TerminateTransactionResult.java	11
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java	65
clients/src/main/java/org/apache/kafka/clients/admin/TopicListing.java	25
clients/src/main/java/org/apache/kafka/clients/admin/TransactionDescription.java	81
clients/src/main/java/org/apache/kafka/clients/admin/TransactionListing.java	46
clients/src/main/java/org/apache/kafka/clients/admin/TransactionState.java	28
clients/src/main/java/org/apache/kafka/clients/admin/UnregisterBrokerOptions.java	3
clients/src/main/java/org/apache/kafka/clients/admin/UnregisterBrokerResult.java	11
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesResult.java	15
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialAlteration.java	11
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialDeletion.java	12
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialUpsertion.java	34
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialsDescription.java	36
clients/src/main/java/org/apache/kafka/clients/admin/internals/AbortTransactionHandler.java	144
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java	355
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiFuture.java	69
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiHandler.java	99
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiLookupStrategy.java	51
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminBootstrapAddresses.java	82
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminFetchMetricsManager.java	17
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java	199
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminUtils.java	21
clients/src/main/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategy.java	153
clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java	160
clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterShareGroupOffsetsHandler.java	126
clients/src/main/java/org/apache/kafka/clients/admin/internals/ApiRequestScope.java	7
clients/src/main/java/org/apache/kafka/clients/admin/internals/CoordinatorKey.java	36
clients/src/main/java/org/apache/kafka/clients/admin/internals/CoordinatorStrategy.java	155
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java	131
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupsHandler.java	17
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteGroupsHandler.java	106
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteRecordsHandler.java	145
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupOffsetsHandler.java	130
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupsHandler.java	17
clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeClassicGroupsHandler.java	150
clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java	326
clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeProducersHandler.java	165
clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeShareGroupsHandler.java	150
clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeStreamsGroupsHandler.java	233
clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeTransactionsHandler.java	153
clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java	113
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java	167
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListOffsetsHandler.java	185
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java	156
clients/src/main/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandler.java	105
clients/src/main/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategy.java	225
clients/src/main/java/org/apache/kafka/clients/admin/internals/RemoveMembersFromConsumerGroupHandler.java	111
clients/src/main/java/org/apache/kafka/clients/admin/internals/StaticBrokerStrategy.java	33
clients/src/main/java/org/apache/kafka/clients/admin/package-info.java	1
clients/src/main/java/org/apache/kafka/clients/consumer/AcknowledgeType.java	29
clients/src/main/java/org/apache/kafka/clients/consumer/AcknowledgementCommitCallback.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/CloseOptions.java	36
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java	69
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java	574
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java	59
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java	9
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java	195
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java	11
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java	124
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java	84
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java	101
clients/src/main/java/org/apache/kafka/clients/consumer/GroupProtocol.java	13
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java	290
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java	148
clients/src/main/java/org/apache/kafka/clients/consumer/LogTruncationException.java	20
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	557
clients/src/main/java/org/apache/kafka/clients/consumer/MockShareConsumer.java	129
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java	20
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java	59
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java	48
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java	9
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java	23
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java	187
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java	15
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java	50
clients/src/main/java/org/apache/kafka/clients/consumer/ShareConsumer.java	34
clients/src/main/java/org/apache/kafka/clients/consumer/ShareConsumerConfig.java	49
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java	96
clients/src/main/java/org/apache/kafka/clients/consumer/SubscriptionPattern.java	24
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	1170
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java	335
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java	284
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java	756
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java	125
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java	1024
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AcknowledgementBatch.java	77
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AcknowledgementCommitCallbackHandler.java	42
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Acknowledgements.java	167
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncClient.java	45
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java	1650
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AutoOffsetResetStrategy.java	129
clients/src/main/java/org/apache/kafka/clients/consumer/internals/BaseHeartbeatThread.java	36
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CachedSupplier.java	12
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java	1002
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java	965
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java	279
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	1203
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegate.java	11
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegateCreator.java	71
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java	218
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java	53
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java	270
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadata.java	71
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java	25
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	446
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java	219
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java	172
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerRebalanceListenerInvoker.java	91
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerRebalanceListenerMethodName.java	14
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java	188
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java	158
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Deserializers.java	69
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetch.java	79
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchBuffer.java	175
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java	271
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchConfig.java	55
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsAggregator.java	43
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsManager.java	230
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsRegistry.java	145
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchRequestManager.java	108
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchUtils.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java	118
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java	103
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestState.java	63
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java	43
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberStateListener.java	9
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java	345
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NodeAcknowledgements.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetAndTimestampInternal.java	49
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java	48
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java	305
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java	331
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java	29
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochUtils.java	106
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java	596
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java	136
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java	7
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManager.java	14
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java	329
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java	98
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SensorBuilder.java	71
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareAcknowledgementMode.java	79
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareCompletedFetch.java	307
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java	1114
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerDelegate.java	9
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerDelegateCreator.java	57
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java	856
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerMetrics.java	12
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareFetch.java	79
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareFetchBuffer.java	157
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareFetchCollector.java	129
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareFetchMetricsAggregator.java	31
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareFetchMetricsManager.java	65
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareFetchMetricsRegistry.java	69
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareHeartbeatRequestManager.java	152
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareInFlightBatch.java	95
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManager.java	99
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java	186
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java	522
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java	829
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java	298
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java	8
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java	954
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TimedRequestState.java	44
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataFetcher.java	96
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java	187
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Utils.java	52
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java	142
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/AbstractTopicMetadataEvent.java	13
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/AllTopicsMetadataEvent.java	6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEvent.java	61
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventHandler.java	79
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java	561
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/AssignmentChangeEvent.java	23
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/AsyncCommitEvent.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/BackgroundEvent.java	51
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/BackgroundEventHandler.java	32
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CheckAndUpdatePositionsEvent.java	13
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CommitEvent.java	39
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CommitOnCloseEvent.java	6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableApplicationEvent.java	26
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableBackgroundEvent.java	23
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEvent.java	27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java	77
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ConsumerRebalanceListenerCallbackCompletedEvent.java	36
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ConsumerRebalanceListenerCallbackNeededEvent.java	31
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CreateFetchRequestsEvent.java	8
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CurrentLagEvent.java	24
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ErrorEvent.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/EventProcessor.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/FetchCommittedOffsetsEvent.java	20
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/LeaveGroupOnCloseEvent.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ListOffsetsEvent.java	39
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/PausePartitionsEvent.java	18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/PollEvent.java	23
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ResetOffsetEvent.java	28
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ResumePartitionsEvent.java	18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/SeekUnvalidatedEvent.java	31
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareAcknowledgeAsyncEvent.java	24
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareAcknowledgeOnCloseEvent.java	18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareAcknowledgeSyncEvent.java	19
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareAcknowledgementCommitCallbackEvent.java	19
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareAcknowledgementCommitCallbackRegistrationEvent.java	11
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareFetchEvent.java	24
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareSubscriptionChangeEvent.java	17
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ShareUnsubscribeEvent.java	6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StopFindCoordinatorOnCloseEvent.java	6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StreamsOnAllTasksLostCallbackCompletedEvent.java	27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StreamsOnAllTasksLostCallbackNeededEvent.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StreamsOnTasksAssignedCallbackCompletedEvent.java	27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StreamsOnTasksAssignedCallbackNeededEvent.java	18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StreamsOnTasksRevokedCallbackCompletedEvent.java	27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/StreamsOnTasksRevokedCallbackNeededEvent.java	19
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/SubscriptionChangeEvent.java	17
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/SyncCommitEvent.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/TopicMetadataEvent.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/TopicPatternSubscriptionChangeEvent.java	18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/TopicRe2JPatternSubscriptionChangeEvent.java	20
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/TopicSubscriptionChangeEvent.java	18
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/UnsubscribeEvent.java	6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/UpdatePatternSubscriptionEvent.java	6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/AsyncConsumerMetrics.java	219
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/ConsumerRebalanceMetricsManager.java	79
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java	52
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/KafkaConsumerMetrics.java	91
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/KafkaShareConsumerMetrics.java	62
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/OffsetCommitMetricsManager.java	41
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceCallbackMetricsManager.java	61
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceMetricsManager.java	17
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/ShareRebalanceMetricsManager.java	37
clients/src/main/java/org/apache/kafka/clients/consumer/package-info.java	1
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java	8
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java	5
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java	831
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java	431
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java	8
clients/src/main/java/org/apache/kafka/clients/producer/PreparedTxnState.java	65
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java	36
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java	528
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java	11
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java	95
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java	48
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java	30
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java	219
clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java	148
clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java	33
clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java	80
clients/src/main/java/org/apache/kafka/clients/producer/internals/IncompleteBatches.java	38
clients/src/main/java/org/apache/kafka/clients/producer/internals/KafkaProducerMetrics.java	100
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java	55
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java	373
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java	81
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java	119
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java	24
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java	731
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java	796
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java	170
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java	1385
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java	55
clients/src/main/java/org/apache/kafka/clients/producer/internals/TxnPartitionEntry.java	115
clients/src/main/java/org/apache/kafka/clients/producer/internals/TxnPartitionMap.java	82
clients/src/main/java/org/apache/kafka/clients/producer/package-info.java	1
clients/src/main/java/org/apache/kafka/common/ClassicGroupState.java	28
clients/src/main/java/org/apache/kafka/common/Cluster.java	243
clients/src/main/java/org/apache/kafka/common/ClusterResource.java	26
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java	4
clients/src/main/java/org/apache/kafka/common/Configurable.java	5
clients/src/main/java/org/apache/kafka/common/ConsumerGroupState.java	31
clients/src/main/java/org/apache/kafka/common/ElectionType.java	20
clients/src/main/java/org/apache/kafka/common/Endpoint.java	59
clients/src/main/java/org/apache/kafka/common/GroupState.java	47
clients/src/main/java/org/apache/kafka/common/GroupType.java	30
clients/src/main/java/org/apache/kafka/common/InvalidRecordException.java	11
clients/src/main/java/org/apache/kafka/common/IsolationLevel.java	26
clients/src/main/java/org/apache/kafka/common/KafkaException.java	16
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java	57
clients/src/main/java/org/apache/kafka/common/MessageFormatter.java	10
clients/src/main/java/org/apache/kafka/common/Metric.java	5
clients/src/main/java/org/apache/kafka/common/MetricName.java	56
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java	55
clients/src/main/java/org/apache/kafka/common/Node.java	90
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java	88
clients/src/main/java/org/apache/kafka/common/Reconfigurable.java	9
clients/src/main/java/org/apache/kafka/common/TopicCollection.java	31
clients/src/main/java/org/apache/kafka/common/TopicIdPartition.java	49
clients/src/main/java/org/apache/kafka/common/TopicPartition.java	44
clients/src/main/java/org/apache/kafka/common/TopicPartitionInfo.java	83
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java	51
clients/src/main/java/org/apache/kafka/common/Uuid.java	100
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java	49
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryData.java	65
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java	60
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java	39
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java	49
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java	51
clients/src/main/java/org/apache/kafka/common/acl/AclPermissionType.java	39
clients/src/main/java/org/apache/kafka/common/acl/package-info.java	1
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java	15
clients/src/main/java/org/apache/kafka/common/annotation/package-info.java	1
clients/src/main/java/org/apache/kafka/common/compress/Compression.java	54
clients/src/main/java/org/apache/kafka/common/compress/GzipCompression.java	72
clients/src/main/java/org/apache/kafka/common/compress/GzipOutputStream.java	13
clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockInputStream.java	209
clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockOutputStream.java	249
clients/src/main/java/org/apache/kafka/common/compress/Lz4Compression.java	69
clients/src/main/java/org/apache/kafka/common/compress/NoCompression.java	29
clients/src/main/java/org/apache/kafka/common/compress/SnappyCompression.java	56
clients/src/main/java/org/apache/kafka/common/compress/ZstdCompression.java	89
clients/src/main/java/org/apache/kafka/common/compress/package-info.java	1
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java	420
clients/src/main/java/org/apache/kafka/common/config/Config.java	11
clients/src/main/java/org/apache/kafka/common/config/ConfigChangeCallback.java	5
clients/src/main/java/org/apache/kafka/common/config/ConfigData.java	20
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java	1043
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java	14
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java	66
clients/src/main/java/org/apache/kafka/common/config/ConfigTransformer.java	107
clients/src/main/java/org/apache/kafka/common/config/ConfigTransformerResult.java	17
clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java	73
clients/src/main/java/org/apache/kafka/common/config/LogLevelConfig.java	16
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java	176
clients/src/main/java/org/apache/kafka/common/config/SecurityConfig.java	7
clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java	25
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java	122
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java	164
clients/src/main/java/org/apache/kafka/common/config/internals/AllowedPaths.java	43
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java	158
clients/src/main/java/org/apache/kafka/common/config/package-info.java	1
clients/src/main/java/org/apache/kafka/common/config/provider/ConfigProvider.java	19
clients/src/main/java/org/apache/kafka/common/config/provider/DirectoryConfigProvider.java	74
clients/src/main/java/org/apache/kafka/common/config/provider/EnvVarConfigProvider.java	69
clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java	89
clients/src/main/java/org/apache/kafka/common/config/provider/package-info.java	1
clients/src/main/java/org/apache/kafka/common/config/types/Password.java	26
clients/src/main/java/org/apache/kafka/common/config/types/package-info.java	1
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java	21
clients/src/main/java/org/apache/kafka/common/errors/ApplicationRecoverableException.java	16
clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java	14
clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/AuthorizerNotReadyException.java	7
clients/src/main/java/org/apache/kafka/common/errors/BrokerIdNotRegisteredException.java	9
clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ConcurrentTransactionsException.java	7
clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorLoadInProgressException.java	10
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorNotAvailableException.java	14
clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java	16
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenAuthorizationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenDisabledException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenExpiredException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenOwnerMismatchException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DisconnectException.java	17
clients/src/main/java/org/apache/kafka/common/errors/DuplicateBrokerRegistrationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/DuplicateResourceException.java	22
clients/src/main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java	6
clients/src/main/java/org/apache/kafka/common/errors/DuplicateVoterException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ElectionNotNeededException.java	9
clients/src/main/java/org/apache/kafka/common/errors/EligibleLeadersNotAvailableException.java	9
clients/src/main/java/org/apache/kafka/common/errors/FeatureUpdateFailedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FencedInstanceIdException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FencedLeaderEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FencedMemberEpochException.java	6
clients/src/main/java/org/apache/kafka/common/errors/FencedStateEpochException.java	7
clients/src/main/java/org/apache/kafka/common/errors/FetchSessionIdNotFoundException.java	9
clients/src/main/java/org/apache/kafka/common/errors/FetchSessionTopicIdException.java	7
clients/src/main/java/org/apache/kafka/common/errors/GroupAuthorizationException.java	17
clients/src/main/java/org/apache/kafka/common/errors/GroupIdNotFoundException.java	6
clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java	7
clients/src/main/java/org/apache/kafka/common/errors/GroupNotEmptyException.java	6
clients/src/main/java/org/apache/kafka/common/errors/GroupSubscribedToTopicException.java	6
clients/src/main/java/org/apache/kafka/common/errors/IllegalGenerationException.java	16
clients/src/main/java/org/apache/kafka/common/errors/IllegalSaslStateException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InconsistentClusterIdException.java	9
clients/src/main/java/org/apache/kafka/common/errors/InconsistentGroupProtocolException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InconsistentTopicIdException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InconsistentVoterSetException.java	10
clients/src/main/java/org/apache/kafka/common/errors/IneligibleReplicaException.java	6
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java	17
clients/src/main/java/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidConfigurationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSessionEpochException.java	9
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSizeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidGroupIdException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidMetadataException.java	16
clients/src/main/java/org/apache/kafka/common/errors/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidPartitionsException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidPidMappingException.java	6
clients/src/main/java/org/apache/kafka/common/errors/InvalidPrincipalTypeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidProducerEpochException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidRecordStateException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidRegistrationException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidRegularExpression.java	6
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicaAssignmentException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicationFactorException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequestException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidSessionTimeoutException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidShareSessionEpochException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidTimestampException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidTopicException.java	34
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnStateException.java	6
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidUpdateVersionException.java	9
clients/src/main/java/org/apache/kafka/common/errors/InvalidVoterKeyException.java	10
clients/src/main/java/org/apache/kafka/common/errors/KafkaStorageException.java	16
clients/src/main/java/org/apache/kafka/common/errors/LeaderNotAvailableException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ListenerNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/LogDirNotFoundException.java	13
clients/src/main/java/org/apache/kafka/common/errors/MemberIdRequiredException.java	10
clients/src/main/java/org/apache/kafka/common/errors/MismatchedEndpointTypeException.java	6
clients/src/main/java/org/apache/kafka/common/errors/NetworkException.java	16
clients/src/main/java/org/apache/kafka/common/errors/NewLeaderElectedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/NoReassignmentInProgressException.java	9
clients/src/main/java/org/apache/kafka/common/errors/NotControllerException.java	10
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorException.java	10
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java	7
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasException.java	16
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderOrFollowerException.java	16
clients/src/main/java/org/apache/kafka/common/errors/OffsetMetadataTooLarge.java	15
clients/src/main/java/org/apache/kafka/common/errors/OffsetMovedToTieredStorageException.java	10
clients/src/main/java/org/apache/kafka/common/errors/OffsetNotAvailableException.java	7
clients/src/main/java/org/apache/kafka/common/errors/OffsetOutOfRangeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/OperationNotAttemptedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/OutOfOrderSequenceException.java	6
clients/src/main/java/org/apache/kafka/common/errors/PolicyViolationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/PositionOutOfRangeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/PreferredLeaderNotAvailableException.java	9
clients/src/main/java/org/apache/kafka/common/errors/PrincipalDeserializationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ProducerFencedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/ReassignmentInProgressException.java	9
clients/src/main/java/org/apache/kafka/common/errors/RebalanceInProgressException.java	16
clients/src/main/java/org/apache/kafka/common/errors/RebootstrapRequiredException.java	10
clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java	16
clients/src/main/java/org/apache/kafka/common/errors/RecordDeserializationException.java	80
clients/src/main/java/org/apache/kafka/common/errors/RecordTooLargeException.java	26
clients/src/main/java/org/apache/kafka/common/errors/RefreshRetriableException.java	15
clients/src/main/java/org/apache/kafka/common/errors/ReplicaNotAvailableException.java	13
clients/src/main/java/org/apache/kafka/common/errors/ResourceNotFoundException.java	22
clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java	15
clients/src/main/java/org/apache/kafka/common/errors/SaslAuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/SecurityDisabledException.java	10
clients/src/main/java/org/apache/kafka/common/errors/SerializationException.java	17
clients/src/main/java/org/apache/kafka/common/errors/ShareSessionLimitReachedException.java	7
clients/src/main/java/org/apache/kafka/common/errors/ShareSessionNotFoundException.java	7
clients/src/main/java/org/apache/kafka/common/errors/SnapshotNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/SslAuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/StaleBrokerEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/StaleMemberEpochException.java	6
clients/src/main/java/org/apache/kafka/common/errors/StreamsInvalidTopologyEpochException.java	6
clients/src/main/java/org/apache/kafka/common/errors/StreamsInvalidTopologyException.java	6
clients/src/main/java/org/apache/kafka/common/errors/StreamsTopologyFencedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/TelemetryTooLargeException.java	6
clients/src/main/java/org/apache/kafka/common/errors/ThrottlingQuotaExceededException.java	14
clients/src/main/java/org/apache/kafka/common/errors/TimeoutException.java	16
clients/src/main/java/org/apache/kafka/common/errors/TopicAuthorizationException.java	19
clients/src/main/java/org/apache/kafka/common/errors/TopicDeletionDisabledException.java	9
clients/src/main/java/org/apache/kafka/common/errors/TopicExistsException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TransactionAbortableException.java	6
clients/src/main/java/org/apache/kafka/common/errors/TransactionAbortedException.java	13
clients/src/main/java/org/apache/kafka/common/errors/TransactionCoordinatorFencedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdAuthorizationException.java	6
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdNotFoundException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnacceptableCredentialException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnknownControllerIdException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnknownLeaderEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnknownMemberIdException.java	16
clients/src/main/java/org/apache/kafka/common/errors/UnknownProducerIdException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnknownServerException.java	15
clients/src/main/java/org/apache/kafka/common/errors/UnknownSubscriptionIdException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicIdException.java	7
clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java	15
clients/src/main/java/org/apache/kafka/common/errors/UnreleasedInstanceIdException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnstableOffsetCommitException.java	7
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedAssignorException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedByAuthenticationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedCompressionTypeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedEndpointTypeException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedForMessageFormatException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedSaslMechanismException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedVersionException.java	11
clients/src/main/java/org/apache/kafka/common/errors/VoterNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/WakeupException.java	5
clients/src/main/java/org/apache/kafka/common/errors/package-info.java	1
clients/src/main/java/org/apache/kafka/common/feature/BaseVersionRange.java	77
clients/src/main/java/org/apache/kafka/common/feature/Features.java	73
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java	20
clients/src/main/java/org/apache/kafka/common/feature/package-info.java	1
clients/src/main/java/org/apache/kafka/common/header/Header.java	5
clients/src/main/java/org/apache/kafka/common/header/Headers.java	9
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java	55
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java	150
clients/src/main/java/org/apache/kafka/common/header/package-info.java	1
clients/src/main/java/org/apache/kafka/common/internals/ClusterResourceListeners.java	26
clients/src/main/java/org/apache/kafka/common/internals/CompositeStrategy.java	67
clients/src/main/java/org/apache/kafka/common/internals/FatalExitError.java	17
clients/src/main/java/org/apache/kafka/common/internals/IdempotentCloser.java	45
clients/src/main/java/org/apache/kafka/common/internals/KafkaCompletableFuture.java	48
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java	162
clients/src/main/java/org/apache/kafka/common/internals/LegacyStrategy.java	49
clients/src/main/java/org/apache/kafka/common/internals/ModernStrategy.java	28
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java	117
clients/src/main/java/org/apache/kafka/common/internals/Plugin.java	67
clients/src/main/java/org/apache/kafka/common/internals/ReflectiveStrategy.java	41
clients/src/main/java/org/apache/kafka/common/internals/SecurityManagerCompatibility.java	13
clients/src/main/java/org/apache/kafka/common/internals/Topic.java	69
clients/src/main/java/org/apache/kafka/common/internals/UnsupportedStrategy.java	31
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java	109
clients/src/main/java/org/apache/kafka/common/memory/MemoryPool.java	34
clients/src/main/java/org/apache/kafka/common/memory/SimpleMemoryPool.java	92
clients/src/main/java/org/apache/kafka/common/memory/package-info.java	1
clients/src/main/java/org/apache/kafka/common/metrics/CompoundStat.java	21
clients/src/main/java/org/apache/kafka/common/metrics/Gauge.java	5
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java	263
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java	62
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetricsContext.java	18
clients/src/main/java/org/apache/kafka/common/metrics/Measurable.java	4
clients/src/main/java/org/apache/kafka/common/metrics/MeasurableStat.java	3
clients/src/main/java/org/apache/kafka/common/metrics/MetricConfig.java	65
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java	2
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java	333
clients/src/main/java/org/apache/kafka/common/metrics/MetricsContext.java	6
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java	22
clients/src/main/java/org/apache/kafka/common/metrics/Monitorable.java	4
clients/src/main/java/org/apache/kafka/common/metrics/PluginMetrics.java	10
clients/src/main/java/org/apache/kafka/common/metrics/Quota.java	45
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java	36
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java	239
clients/src/main/java/org/apache/kafka/common/metrics/Stat.java	4
clients/src/main/java/org/apache/kafka/common/metrics/internals/IntGaugeSuite.java	184
clients/src/main/java/org/apache/kafka/common/metrics/internals/MetricsUtils.java	35
clients/src/main/java/org/apache/kafka/common/metrics/internals/PluginMetricsImpl.java	85
clients/src/main/java/org/apache/kafka/common/metrics/package-info.java	1
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeCount.java	8
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeSum.java	24
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequencies.java	107
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequency.java	23
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java	127
clients/src/main/java/org/apache/kafka/common/metrics/stats/Max.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/Meter.java	52
clients/src/main/java/org/apache/kafka/common/metrics/stats/Min.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentile.java	17
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java	109
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java	51
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java	111
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java	10
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java	52
clients/src/main/java/org/apache/kafka/common/metrics/stats/Value.java	14
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedCount.java	8
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedSum.java	19
clients/src/main/java/org/apache/kafka/common/metrics/stats/package-info.java	1
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java	32
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java	54
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java	11
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java	167
clients/src/main/java/org/apache/kafka/common/network/ChannelMetadataRegistry.java	9
clients/src/main/java/org/apache/kafka/common/network/ChannelState.java	42
clients/src/main/java/org/apache/kafka/common/network/CipherInformation.java	37
clients/src/main/java/org/apache/kafka/common/network/ClientInformation.java	39
clients/src/main/java/org/apache/kafka/common/network/ConnectionMode.java	2
clients/src/main/java/org/apache/kafka/common/network/DelayedResponseAuthenticationException.java	8
clients/src/main/java/org/apache/kafka/common/network/InvalidReceiveException.java	7
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java	360
clients/src/main/java/org/apache/kafka/common/network/ListenerName.java	50
clients/src/main/java/org/apache/kafka/common/network/ListenerReconfigurable.java	5
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java	107
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java	28
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java	80
clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java	107
clients/src/main/java/org/apache/kafka/common/network/ReauthenticationContext.java	21
clients/src/main/java/org/apache/kafka/common/network/Receive.java	11
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java	345
clients/src/main/java/org/apache/kafka/common/network/Selectable.java	25
clients/src/main/java/org/apache/kafka/common/network/Selector.java	1030
clients/src/main/java/org/apache/kafka/common/network/Send.java	7
clients/src/main/java/org/apache/kafka/common/network/ServerConnectionId.java	85
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java	129
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java	697
clients/src/main/java/org/apache/kafka/common/network/TransferableChannel.java	8
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java	21
clients/src/main/java/org/apache/kafka/common/network/package-info.java	1
clients/src/main/java/org/apache/kafka/common/package-info.java	1
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java	284
clients/src/main/java/org/apache/kafka/common/protocol/ApiMessage.java	4
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java	113
clients/src/main/java/org/apache/kafka/common/protocol/DataOutputStreamWritable.java	113
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java	492
clients/src/main/java/org/apache/kafka/common/protocol/Message.java	17
clients/src/main/java/org/apache/kafka/common/protocol/MessageSizeAccumulator.java	22
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java	207
clients/src/main/java/org/apache/kafka/common/protocol/ObjectSerializationCache.java	21
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java	193
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java	51
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java	158
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java	39
clients/src/main/java/org/apache/kafka/common/protocol/package-info.java	1
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java	92
clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java	15
clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java	99
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java	146
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedField.java	31
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriter.java	48
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java	143
clients/src/main/java/org/apache/kafka/common/protocol/types/SchemaException.java	11
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java	432
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java	145
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java	910
clients/src/main/java/org/apache/kafka/common/protocol/types/package-info.java	1
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaAlteration.java	50
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaEntity.java	35
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilter.java	42
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilterComponent.java	41
clients/src/main/java/org/apache/kafka/common/quota/package-info.java	1
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java	464
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java	15
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java	104
clients/src/main/java/org/apache/kafka/common/record/BaseRecords.java	5
clients/src/main/java/org/apache/kafka/common/record/ByteBufferLogInputStream.java	47
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java	55
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java	133
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java	76
clients/src/main/java/org/apache/kafka/common/record/ControlRecordUtils.java	67
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java	401
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java	541
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordsSend.java	15
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java	71
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java	186
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java	332
clients/src/main/java/org/apache/kafka/common/record/LegacyRecord.java	336
clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java	5
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java	639
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java	567
clients/src/main/java/org/apache/kafka/common/record/MultiRecordsSend.java	71
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java	11
clients/src/main/java/org/apache/kafka/common/record/PartialDefaultRecord.java	67
clients/src/main/java/org/apache/kafka/common/record/Record.java	21
clients/src/main/java/org/apache/kafka/common/record/RecordBatch.java	53
clients/src/main/java/org/apache/kafka/common/record/RecordBatchIterator.java	25
clients/src/main/java/org/apache/kafka/common/record/RecordValidationStats.java	34
clients/src/main/java/org/apache/kafka/common/record/RecordVersion.java	17
clients/src/main/java/org/apache/kafka/common/record/Records.java	19
clients/src/main/java/org/apache/kafka/common/record/RecordsSend.java	44
clients/src/main/java/org/apache/kafka/common/record/RemoteLogInputStream.java	43
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java	82
clients/src/main/java/org/apache/kafka/common/record/TimestampType.java	21
clients/src/main/java/org/apache/kafka/common/record/TransferableRecords.java	6
clients/src/main/java/org/apache/kafka/common/record/UnalignedFileRecords.java	24
clients/src/main/java/org/apache/kafka/common/record/UnalignedMemoryRecords.java	30
clients/src/main/java/org/apache/kafka/common/record/UnalignedRecords.java	7
clients/src/main/java/org/apache/kafka/common/record/package-info.java	1
clients/src/main/java/org/apache/kafka/common/replica/ClientMetadata.java	71
clients/src/main/java/org/apache/kafka/common/replica/PartitionView.java	43
clients/src/main/java/org/apache/kafka/common/replica/RackAwareReplicaSelector.java	28
clients/src/main/java/org/apache/kafka/common/replica/ReplicaSelector.java	18
clients/src/main/java/org/apache/kafka/common/replica/ReplicaView.java	57
clients/src/main/java/org/apache/kafka/common/replica/package-info.java	1
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java	285
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java	5
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java	262
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java	41
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java	40
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java	154
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java	106
clients/src/main/java/org/apache/kafka/common/requests/AddRaftVoterRequest.java	45
clients/src/main/java/org/apache/kafka/common/requests/AddRaftVoterResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/AllocateProducerIdsRequest.java	42
clients/src/main/java/org/apache/kafka/common/requests/AllocateProducerIdsResponse.java	37
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasRequest.java	106
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java	85
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java	97
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsRequest.java	70
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java	61
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java	56
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java	36
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java	67
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java	85
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java	252
clients/src/main/java/org/apache/kafka/common/requests/AssignReplicasToDirsRequest.java	45
clients/src/main/java/org/apache/kafka/common/requests/AssignReplicasToDirsResponse.java	34
clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java	40
clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatRequest.java	43
clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/BrokerRegistrationRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/BrokerRegistrationResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeRequest.java	66
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatRequest.java	58
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java	50
clients/src/main/java/org/apache/kafka/common/requests/ControllerRegistrationRequest.java	45
clients/src/main/java/org/apache/kafka/common/requests/ControllerRegistrationResponse.java	34
clients/src/main/java/org/apache/kafka/common/requests/CorrelationIdMismatchException.java	20
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	101
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java	40
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java	41
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java	75
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java	50
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	81
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	106
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java	110
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java	56
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java	57
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsRequest.java	59
clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsResponse.java	40
clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupStateRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupStateResponse.java	93
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java	86
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java	88
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java	128
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java	94
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java	88
clients/src/main/java/org/apache/kafka/common/requests/DescribeClusterRequest.java	45
clients/src/main/java/org/apache/kafka/common/requests/DescribeClusterResponse.java	40
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java	45
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java	198
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java	51
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java	97
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java	112
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java	44
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/DescribeProducersRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/DescribeProducersResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumRequest.java	74
clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java	67
clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java	73
clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java	68
clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsRequest.java	49
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java	36
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java	111
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java	76
clients/src/main/java/org/apache/kafka/common/requests/EndQuorumEpochRequest.java	83
clients/src/main/java/org/apache/kafka/common/requests/EndQuorumEpochResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/EnvelopeRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/EnvelopeResponse.java	47
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java	50
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/FetchMetadata.java	76
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java	382
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	195
clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java	61
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java	102
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java	137
clients/src/main/java/org/apache/kafka/common/requests/GetTelemetrySubscriptionsRequest.java	46
clients/src/main/java/org/apache/kafka/common/requests/GetTelemetrySubscriptionsResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java	49
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsRequest.java	78
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java	71
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java	96
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java	101
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java	52
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java	321
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java	60
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java	89
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java	113
clients/src/main/java/org/apache/kafka/common/requests/ListClientMetricsResourcesRequest.java	47
clients/src/main/java/org/apache/kafka/common/requests/ListClientMetricsResourcesResponse.java	48
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java	36
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java	150
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsResponse.java	69
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsRequest.java	62
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java	37
clients/src/main/java/org/apache/kafka/common/requests/ListTransactionsRequest.java	56
clients/src/main/java/org/apache/kafka/common/requests/ListTransactionsResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java	158
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java	378
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java	109
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java	206
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteRequest.java	46
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java	110
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java	200
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java	307
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java	80
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java	171
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java	206
clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryRequest.java	61
clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateRequest.java	56
clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateResponse.java	96
clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryRequest.java	56
clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java	107
clients/src/main/java/org/apache/kafka/common/requests/RemoveRaftVoterRequest.java	45
clients/src/main/java/org/apache/kafka/common/requests/RemoveRaftVoterResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java	43
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/RequestAndSize.java	9
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java	169
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java	115
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java	63
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java	66
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java	43
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java	40
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/ShareAcknowledgeRequest.java	84
clients/src/main/java/org/apache/kafka/common/requests/ShareAcknowledgeResponse.java	100
clients/src/main/java/org/apache/kafka/common/requests/ShareFetchRequest.java	166
clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java	130
clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeRequest.java	65
clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/ShareGroupHeartbeatRequest.java	46
clients/src/main/java/org/apache/kafka/common/requests/ShareGroupHeartbeatResponse.java	50
clients/src/main/java/org/apache/kafka/common/requests/ShareRequestMetadata.java	60
clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeRequest.java	66
clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupHeartbeatRequest.java	50
clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupHeartbeatResponse.java	53
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java	63
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/TransactionResult.java	14
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java	214
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java	138
clients/src/main/java/org/apache/kafka/common/requests/UnregisterBrokerRequest.java	40
clients/src/main/java/org/apache/kafka/common/requests/UnregisterBrokerResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesRequest.java	84
clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java	67
clients/src/main/java/org/apache/kafka/common/requests/UpdateRaftVoterRequest.java	43
clients/src/main/java/org/apache/kafka/common/requests/UpdateRaftVoterResponse.java	37
clients/src/main/java/org/apache/kafka/common/requests/VoteRequest.java	64
clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/WriteShareGroupStateRequest.java	56
clients/src/main/java/org/apache/kafka/common/requests/WriteShareGroupStateResponse.java	90
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java	162
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java	84
clients/src/main/java/org/apache/kafka/common/requests/package-info.java	1
clients/src/main/java/org/apache/kafka/common/resource/PatternType.java	42
clients/src/main/java/org/apache/kafka/common/resource/Resource.java	38
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java	53
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java	83
clients/src/main/java/org/apache/kafka/common/resource/ResourceType.java	43
clients/src/main/java/org/apache/kafka/common/resource/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java	83
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java	136
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java	9
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticateCallbackHandler.java	9
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticationContext.java	7
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java	49
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalBuilder.java	4
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalSerde.java	6
clients/src/main/java/org/apache/kafka/common/security/auth/Login.java	14
clients/src/main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java	22
clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java	43
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensions.java	33
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensionsCallback.java	12
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProtocol.java	41
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProviderCreator.java	9
clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java	28
clients/src/main/java/org/apache/kafka/common/security/auth/SslEngineFactory.java	15
clients/src/main/java/org/apache/kafka/common/security/auth/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java	74
clients/src/main/java/org/apache/kafka/common/security/authenticator/CredentialCache.java	41
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java	93
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java	10
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java	188
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	530
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java	74
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslInternalConfigs.java	7
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java	568
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java	46
clients/src/main/java/org/apache/kafka/common/security/authenticator/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/kerberos/BadFormatString.java	10
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosClientCallbackHandler.java	51
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosError.java	84
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java	299
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosName.java	51
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java	141
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java	63
clients/src/main/java/org/apache/kafka/common/security/kerberos/NoMatchingRule.java	7
clients/src/main/java/org/apache/kafka/common/security/kerberos/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallback.java	43
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginCallbackHandler.java	132
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.java	179
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerToken.java	9
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallback.java	35
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallback.java	44
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackHandler.java	140
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponse.java	95
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerRefreshingLogin.java	77
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java	145
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientCallbackHandler.java	81
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServer.java	175
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredential.java	7
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfig.java	34
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLogin.java	307
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenRetriever.java	8
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenRetrieverFactory.java	56
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenValidator.java	5
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenValidatorFactory.java	44
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/BasicOAuthBearerToken.java	52
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ClaimValidationUtils.java	47
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/CloseableVerificationKeyResolver.java	9
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ConfigurationUtils.java	133
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/FileTokenRetriever.java	22
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java	267
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/Initable.java	6
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/JaasOptionsUtils.java	68
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/JwksFileVerificationKeyResolver.java	41
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/LoginAccessTokenValidator.java	60
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwks.java	184
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksVerificationKeyResolver.java	66
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/Retry.java	56
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/Retryable.java	5
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/SerializedJwt.java	40
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/UnretryableException.java	7
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ValidateException.java	14
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ValidatorAccessTokenValidator.java	90
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/VerificationKeyResolverFactory.java	48
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerConfigException.java	11
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerIllegalTokenException.java	16
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtils.java	25
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJws.java	203
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandler.java	230
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandler.java	126
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationResult.java	44
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtils.java	97
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/plain/PlainAuthenticateCallback.java	18
clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java	38
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServer.java	121
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServerProvider.java	14
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java	49
clients/src/main/java/org/apache/kafka/common/security/plain/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredential.java	25
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialCallback.java	11
clients/src/main/java/org/apache/kafka/common/security/scram/ScramExtensionsCallback.java	13
clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java	47
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramCredentialUtils.java	53
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramExtensions.java	20
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramFormatter.java	143
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramMechanism.java	63
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramMessages.java	217
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java	193
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClientProvider.java	15
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java	208
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServerProvider.java	15
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramServerCallbackHandler.java	51
clients/src/main/java/org/apache/kafka/common/security/scram/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/ssl/CommonNameLoggingSslEngineFactory.java	14
clients/src/main/java/org/apache/kafka/common/security/ssl/CommonNameLoggingTrustManagerFactoryWrapper.java	302
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java	482
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java	392
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java	156
clients/src/main/java/org/apache/kafka/common/security/ssl/package-info.java	1
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java	46
clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java	105
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCache.java	81
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCredentialCallback.java	18
clients/src/main/java/org/apache/kafka/common/security/token/delegation/package-info.java	1
clients/src/main/java/org/apache/kafka/common/serialization/BooleanDeserializer.java	41
clients/src/main/java/org/apache/kafka/common/serialization/BooleanSerializer.java	14
clients/src/main/java/org/apache/kafka/common/serialization/ByteArrayDeserializer.java	7
clients/src/main/java/org/apache/kafka/common/serialization/ByteArraySerializer.java	7
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferDeserializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferSerializer.java	19
clients/src/main/java/org/apache/kafka/common/serialization/BytesDeserializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/BytesSerializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java	20
clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java	19
clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java	13
clients/src/main/java/org/apache/kafka/common/serialization/ListDeserializer.java	165
clients/src/main/java/org/apache/kafka/common/serialization/ListSerializer.java	117
clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/Serde.java	12
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	194
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java	11
clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java	45
clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java	32
clients/src/main/java/org/apache/kafka/common/serialization/UUIDDeserializer.java	50
clients/src/main/java/org/apache/kafka/common/serialization/UUIDSerializer.java	29
clients/src/main/java/org/apache/kafka/common/serialization/VoidDeserializer.java	18
clients/src/main/java/org/apache/kafka/common/serialization/VoidSerializer.java	7
clients/src/main/java/org/apache/kafka/common/serialization/package-info.java	1
clients/src/main/java/org/apache/kafka/common/telemetry/ClientTelemetryState.java	51
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryEmitter.java	35
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryProvider.java	81
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java	669
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetrySender.java	19
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java	172
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java	165
clients/src/main/java/org/apache/kafka/common/telemetry/internals/LastValueTracker.java	40
clients/src/main/java/org/apache/kafka/common/telemetry/internals/MetricKey.java	48
clients/src/main/java/org/apache/kafka/common/telemetry/internals/MetricKeyable.java	4
clients/src/main/java/org/apache/kafka/common/telemetry/internals/MetricNamingStrategy.java	6
clients/src/main/java/org/apache/kafka/common/telemetry/internals/MetricsCollector.java	8
clients/src/main/java/org/apache/kafka/common/telemetry/internals/MetricsEmitter.java	19
clients/src/main/java/org/apache/kafka/common/telemetry/internals/SinglePointMetric.java	93
clients/src/main/java/org/apache/kafka/common/telemetry/internals/TelemetryMetricNamingConvention.java	54
clients/src/main/java/org/apache/kafka/common/utils/AbstractIterator.java	56
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java	116
clients/src/main/java/org/apache/kafka/common/utils/BufferSupplier.java	68
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java	31
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferOutputStream.java	65
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferUnmapper.java	55
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java	256
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java	116
clients/src/main/java/org/apache/kafka/common/utils/Checksums.java	48
clients/src/main/java/org/apache/kafka/common/utils/ChildFirstClassLoader.java	90
clients/src/main/java/org/apache/kafka/common/utils/ChunkedBytesStream.java	148
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java	41
clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java	24
clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java	48
clients/src/main/java/org/apache/kafka/common/utils/ConfigUtils.java	49
clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java	105
clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java	17
clients/src/main/java/org/apache/kafka/common/utils/Exit.java	61
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java	40
clients/src/main/java/org/apache/kafka/common/utils/FixedOrderMap.java	25
clients/src/main/java/org/apache/kafka/common/utils/FlattenedIterator.java	22
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java	416
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java	74
clients/src/main/java/org/apache/kafka/common/utils/Java.java	10
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java	26
clients/src/main/java/org/apache/kafka/common/utils/LogContext.java	636
clients/src/main/java/org/apache/kafka/common/utils/LoggingSignalHandler.java	68
clients/src/main/java/org/apache/kafka/common/utils/MappedIterator.java	19
clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java	14
clients/src/main/java/org/apache/kafka/common/utils/PrimitiveRef.java	29
clients/src/main/java/org/apache/kafka/common/utils/ProducerIdAndEpoch.java	32
clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java	30
clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java	10
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java	129
clients/src/main/java/org/apache/kafka/common/utils/Shell.java	164
clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java	18
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java	36
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java	56
clients/src/main/java/org/apache/kafka/common/utils/Time.java	41
clients/src/main/java/org/apache/kafka/common/utils/Timer.java	66
clients/src/main/java/org/apache/kafka/common/utils/Utils.java	924
clients/src/main/java/org/apache/kafka/common/utils/package-info.java	1
clients/src/main/java/org/apache/kafka/server/authorizer/AclCreateResult.java	16
clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java	43
clients/src/main/java/org/apache/kafka/server/authorizer/Action.java	66
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java	14
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java	5
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java	121
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java	11
clients/src/main/java/org/apache/kafka/server/authorizer/package-info.java	1
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java	39
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java	64
clients/src/main/java/org/apache/kafka/server/policy/package-info.java	1
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaCallback.java	14
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaEntity.java	15
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaType.java	7
clients/src/main/java/org/apache/kafka/server/quota/package-info.java	1
clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetry.java	5
clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryPayload.java	9
clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryReceiver.java	5
clients/src/main/java/org/apache/kafka/server/telemetry/package-info.java	1