Path	Lines of Code
clients/src/main/java/org/apache/kafka/clients/ApiVersion.java	29
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java	32
clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java	18
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java	85
clients/src/main/java/org/apache/kafka/clients/ClientResponse.java	79
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java	97
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java	273
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java	137
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java	10
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java	310
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java	64
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java	97
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java	37
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java	45
clients/src/main/java/org/apache/kafka/clients/Metadata.java	369
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java	144
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java	20
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java	903
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java	59
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java	138
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/AbstractOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java	222
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java	11
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java	175
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java	61
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java	59
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java	26
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsResult.java	20
clients/src/main/java/org/apache/kafka/clients/admin/Config.java	38
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java	165
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java	92
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java	61
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java	19
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenResult.java	14
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java	17
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java	26
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java	65
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java	64
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java	59
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java	12
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasOptions.java	5
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasResult.java	15
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java	26
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java	34
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenOptions.java	15
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenResult.java	15
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java	68
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java	82
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java	31
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java	83
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersOptions.java	7
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java	40
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersOptions.java	9
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java	61
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java	3377
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java	15
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java	48
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsResult.java	64
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsOptions.java	5
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java	22
clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java	26
clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java	32
clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java	67
clients/src/main/java/org/apache/kafka/clients/admin/MemberToRemove.java	31
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitionReassignment.java	16
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java	29
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java	102
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java	24
clients/src/main/java/org/apache/kafka/clients/admin/PartitionReassignment.java	30
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java	31
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java	25
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java	77
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenResult.java	13
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	30
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java	55
clients/src/main/java/org/apache/kafka/clients/admin/TopicListing.java	19
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	38
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java	151
clients/src/main/java/org/apache/kafka/clients/admin/internals/ConsumerGroupOperationContext.java	50
clients/src/main/java/org/apache/kafka/clients/admin/internals/MetadataOperationContext.java	59
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java	66
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java	450
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	119
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java	11
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java	140
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java	76
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java	62
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java	879
clients/src/main/java/org/apache/kafka/clients/consumer/LogTruncationException.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	451
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java	25
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	8
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java	23
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java	4
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java	50
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java	15
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java	49
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java	96
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	1047
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java	84
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java	691
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncClient.java	49
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	1046
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java	47
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadata.java	56
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java	26
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	453
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java	212
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java	1432
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java	143
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java	94
clients/src/main/java/org/apache/kafka/clients/consumer/internals/KafkaConsumerMetrics.java	61
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java	98
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java	63
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapter.java	93
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/SubscriptionState.java	795
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java	8
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java	4
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java	692
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java	374
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java	10
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java	35
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java	418
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java	7
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java	95
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java	57
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java	33
clients/src/main/java/org/apache/kafka/clients/producer/UniformStickyPartitioner.java	15
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java	216
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java	23
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	84
clients/src/main/java/org/apache/kafka/clients/producer/internals/IncompleteBatches.java	32
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java	50
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java	319
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java	68
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java	109
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java	27
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java	516
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java	657
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java	171
clients/src/main/java/org/apache/kafka/clients/producer/internals/StickyPartitionCache.java	47
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java	1333
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java	59
clients/src/main/java/org/apache/kafka/common/Cluster.java	213
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	29
clients/src/main/java/org/apache/kafka/common/ElectionType.java	22
clients/src/main/java/org/apache/kafka/common/Endpoint.java	57
clients/src/main/java/org/apache/kafka/common/InvalidRecordException.java	11
clients/src/main/java/org/apache/kafka/common/IsolationLevel.java	21
clients/src/main/java/org/apache/kafka/common/KafkaException.java	16
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java	74
clients/src/main/java/org/apache/kafka/common/MessageFormatter.java	17
clients/src/main/java/org/apache/kafka/common/Metric.java	7
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	75
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java	65
clients/src/main/java/org/apache/kafka/common/Reconfigurable.java	9
clients/src/main/java/org/apache/kafka/common/TopicPartition.java	45
clients/src/main/java/org/apache/kafka/common/TopicPartitionInfo.java	51
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java	51
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java	51
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryData.java	65
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java	62
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java	47
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java	57
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java	50
clients/src/main/java/org/apache/kafka/common/acl/AclPermissionType.java	41
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java	16
clients/src/main/java/org/apache/kafka/common/cache/Cache.java	7
clients/src/main/java/org/apache/kafka/common/cache/LRUCache.java	30
clients/src/main/java/org/apache/kafka/common/cache/SynchronizedCache.java	23
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java	359
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	984
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java	14
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java	61
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	79
clients/src/main/java/org/apache/kafka/common/config/LogLevelConfig.java	16
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java	96
clients/src/main/java/org/apache/kafka/common/config/SecurityConfig.java	7
clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java	24
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java	123
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java	133
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java	60
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	59
clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java	61
clients/src/main/java/org/apache/kafka/common/config/types/Password.java	26
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java	21
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/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/DuplicateResourceException.java	22
clients/src/main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java	6
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/FencedInstanceIdException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FencedLeaderEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FetchSessionIdNotFoundException.java	9
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/InconsistentGroupProtocolException.java	10
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/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/InvalidTimestampException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidTopicException.java	30
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/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/NetworkException.java	16
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/NotLeaderForPartitionException.java	17
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderOrFollowerException.java	17
clients/src/main/java/org/apache/kafka/common/errors/OffsetMetadataTooLarge.java	15
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/PreferredLeaderNotAvailableException.java	9
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/RecordBatchTooLargeException.java	16
clients/src/main/java/org/apache/kafka/common/errors/RecordTooLargeException.java	26
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	21
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/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/TransactionCoordinatorFencedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdAuthorizationException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnacceptableCredentialException.java	10
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/UnknownTopicOrPartitionException.java	15
clients/src/main/java/org/apache/kafka/common/errors/UnstableOffsetCommitException.java	7
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/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/WakeupException.java	5
clients/src/main/java/org/apache/kafka/common/feature/BaseVersionRange.java	66
clients/src/main/java/org/apache/kafka/common/feature/Features.java	83
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java	17
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java	14
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	51
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java	152
clients/src/main/java/org/apache/kafka/common/internals/ClusterResourceListeners.java	26
clients/src/main/java/org/apache/kafka/common/internals/FatalExitError.java	17
clients/src/main/java/org/apache/kafka/common/internals/InvalidProducerEpochException.java	8
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java	213
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java	113
clients/src/main/java/org/apache/kafka/common/internals/Topic.java	44
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java	110
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/metrics/CompoundStat.java	21
clients/src/main/java/org/apache/kafka/common/metrics/Gauge.java	4
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java	268
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java	64
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	64
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java	2
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java	329
clients/src/main/java/org/apache/kafka/common/metrics/MetricsContext.java	8
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java	24
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	222
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	24
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/Count.java	4
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	20
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequencies.java	112
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequency.java	16
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java	129
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	43
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	47
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java	87
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java	10
clients/src/main/java/org/apache/kafka/common/metrics/stats/Sum.java	4
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java	44
clients/src/main/java/org/apache/kafka/common/metrics/stats/Total.java	4
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/network/Authenticator.java	30
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java	52
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java	11
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java	164
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/DefaultChannelMetadataRegistry.java	28
clients/src/main/java/org/apache/kafka/common/network/DelayedResponseAuthenticationException.java	8
clients/src/main/java/org/apache/kafka/common/network/InvalidReceiveException.java	10
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java	353
clients/src/main/java/org/apache/kafka/common/network/ListenerName.java	45
clients/src/main/java/org/apache/kafka/common/network/ListenerReconfigurable.java	5
clients/src/main/java/org/apache/kafka/common/network/Mode.java	2
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java	118
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java	13
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java	76
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	331
clients/src/main/java/org/apache/kafka/common/network/Selectable.java	24
clients/src/main/java/org/apache/kafka/common/network/Selector.java	1023
clients/src/main/java/org/apache/kafka/common/network/Send.java	9
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java	129
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java	660
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java	25
clients/src/main/java/org/apache/kafka/common/network/TransportLayers.java	10
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java	346
clients/src/main/java/org/apache/kafka/common/protocol/ApiMessage.java	4
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java	76
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java	23
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java	400
clients/src/main/java/org/apache/kafka/common/protocol/Message.java	15
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java	143
clients/src/main/java/org/apache/kafka/common/protocol/ObjectSerializationCache.java	23
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java	151
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java	34
clients/src/main/java/org/apache/kafka/common/protocol/RecordsReadable.java	54
clients/src/main/java/org/apache/kafka/common/protocol/RecordsWritable.java	71
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java	17
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	136
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	401
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java	141
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java	866
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaAlteration.java	50
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaEntity.java	29
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/record/AbstractLegacyRecordBatch.java	457
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java	15
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java	102
clients/src/main/java/org/apache/kafka/common/record/BaseRecords.java	5
clients/src/main/java/org/apache/kafka/common/record/BufferSupplier.java	72
clients/src/main/java/org/apache/kafka/common/record/ByteBufferLogInputStream.java	47
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java	58
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java	159
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java	58
clients/src/main/java/org/apache/kafka/common/record/ConvertedRecords.java	15
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java	485
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java	524
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordsSend.java	15
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java	83
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java	185
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java	327
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java	192
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java	270
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecords.java	110
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecordsSend.java	57
clients/src/main/java/org/apache/kafka/common/record/LegacyRecord.java	338
clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java	5
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java	471
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java	486
clients/src/main/java/org/apache/kafka/common/record/MultiRecordsSend.java	89
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java	10
clients/src/main/java/org/apache/kafka/common/record/PartialDefaultRecord.java	67
clients/src/main/java/org/apache/kafka/common/record/Record.java	23
clients/src/main/java/org/apache/kafka/common/record/RecordBatch.java	38
clients/src/main/java/org/apache/kafka/common/record/RecordBatchIterator.java	21
clients/src/main/java/org/apache/kafka/common/record/RecordConversionStats.java	34
clients/src/main/java/org/apache/kafka/common/record/RecordVersion.java	20
clients/src/main/java/org/apache/kafka/common/record/Records.java	23
clients/src/main/java/org/apache/kafka/common/record/RecordsSend.java	51
clients/src/main/java/org/apache/kafka/common/record/RecordsUtil.java	87
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java	79
clients/src/main/java/org/apache/kafka/common/record/TimestampType.java	21
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/requests/AbstractControlRequest.java	22
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java	188
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java	3
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java	172
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java	46
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java	99
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java	82
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasRequest.java	96
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java	94
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java	101
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java	45
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsRequest.java	78
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java	48
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java	69
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java	63
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java	82
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java	160
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java	48
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	105
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java	47
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java	68
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	81
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	111
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java	109
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java	59
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java	62
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java	96
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java	120
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java	88
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java	91
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java	216
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java	83
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java	116
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java	49
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java	87
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java	95
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java	88
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java	45
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java	56
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/FetchMetadata.java	73
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java	290
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	279
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java	81
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java	61
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java	67
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java	99
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java	52
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java	138
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java	90
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java	106
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java	59
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java	260
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java	211
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsRequest.java	74
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java	127
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java	387
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java	100
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java	73
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteRequest.java	52
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java	47
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java	140
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java	153
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java	174
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java	130
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java	305
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java	274
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java	50
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/RequestAndSize.java	9
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java	111
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java	105
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java	27
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java	39
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java	51
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java	34
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java	175
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/TransactionResult.java	14
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java	202
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java	73
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java	165
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java	30
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java	163
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java	76
clients/src/main/java/org/apache/kafka/common/resource/PatternType.java	44
clients/src/main/java/org/apache/kafka/common/resource/Resource.java	43
clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java	55
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java	55
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java	85
clients/src/main/java/org/apache/kafka/common/resource/ResourceType.java	44
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java	83
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java	119
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java	48
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/DefaultPrincipalBuilder.java	18
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java	50
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalBuilder.java	4
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/PrincipalBuilder.java	15
clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java	30
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensions.java	28
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	11
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/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	112
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	156
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	516
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/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	72
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java	289
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/oauthbearer/OAuthBearerExtensionsValidatorCallback.java	43
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	11
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallback.java	37
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallback.java	46
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	146
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientCallbackHandler.java	86
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	176
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/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	204
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandler.java	236
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandler.java	136
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/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	122
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServerProvider.java	15
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java	49
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	47
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	192
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClientProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java	207
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServerProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramServerCallbackHandler.java	51
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java	265
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java	347
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java	156
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java	47
clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java	93
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/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	9
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	15
clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java	18
clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java	19
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedDeserializer.java	32
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedSerializer.java	32
clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java	18
clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java	13
clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java	17
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	165
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java	11
clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java	27
clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java	27
clients/src/main/java/org/apache/kafka/common/serialization/UUIDDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/UUIDSerializer.java	28
clients/src/main/java/org/apache/kafka/common/serialization/VoidDeserializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/VoidSerializer.java	7
clients/src/main/java/org/apache/kafka/common/utils/AbstractIterator.java	56
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java	111
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java	23
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferOutputStream.java	65
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferUnmapper.java	83
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java	186
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java	116
clients/src/main/java/org/apache/kafka/common/utils/Checksums.java	35
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	35
clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java	105
clients/src/main/java/org/apache/kafka/common/utils/Crc32.java	314
clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java	57
clients/src/main/java/org/apache/kafka/common/utils/Exit.java	66
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java	24
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	401
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java	74
clients/src/main/java/org/apache/kafka/common/utils/Java.java	40
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java	24
clients/src/main/java/org/apache/kafka/common/utils/LogContext.java	631
clients/src/main/java/org/apache/kafka/common/utils/LoggingSignalHandler.java	64
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	12
clients/src/main/java/org/apache/kafka/common/utils/ProducerIdAndEpoch.java	32
clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java	582
clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java	41
clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java	10
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java	110
clients/src/main/java/org/apache/kafka/common/utils/Shell.java	168
clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java	18
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java	30
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java	23
clients/src/main/java/org/apache/kafka/common/utils/Time.java	20
clients/src/main/java/org/apache/kafka/common/utils/Timer.java	51
clients/src/main/java/org/apache/kafka/common/utils/Utils.java	723
clients/src/main/java/org/apache/kafka/server/authorizer/AclCreateResult.java	18
clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java	45
clients/src/main/java/org/apache/kafka/server/authorizer/Action.java	68
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java	19
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java	7
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java	18
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java	12
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java	27
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java	47
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