Path	Lines of Code
metadata/src/main/java/org/apache/kafka/common/errors/InvalidReplicaDirectoriesException.java	12
metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java	197
metadata/src/main/java/org/apache/kafka/controller/ActivationRecordsGenerator.java	124
metadata/src/main/java/org/apache/kafka/controller/BrokerControlState.java	22
metadata/src/main/java/org/apache/kafka/controller/BrokerControlStates.java	29
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java	307
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatTracker.java	54
metadata/src/main/java/org/apache/kafka/controller/BrokerIdAndEpoch.java	32
metadata/src/main/java/org/apache/kafka/controller/BrokersToElrs.java	121
metadata/src/main/java/org/apache/kafka/controller/BrokersToIsrs.java	220
metadata/src/main/java/org/apache/kafka/controller/ClientQuotaControlManager.java	265
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java	650
metadata/src/main/java/org/apache/kafka/controller/ClusterFeatureSupportDescriber.java	9
metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java	591
metadata/src/main/java/org/apache/kafka/controller/ConfigurationValidator.java	13
metadata/src/main/java/org/apache/kafka/controller/Controller.java	161
metadata/src/main/java/org/apache/kafka/controller/ControllerRequestContext.java	74
metadata/src/main/java/org/apache/kafka/controller/ControllerResult.java	57
metadata/src/main/java/org/apache/kafka/controller/ControllerResultAndOffset.java	42
metadata/src/main/java/org/apache/kafka/controller/DelegationTokenControlManager.java	274
metadata/src/main/java/org/apache/kafka/controller/EventPerformanceMonitor.java	109
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java	376
metadata/src/main/java/org/apache/kafka/controller/KRaftVersionAccessor.java	6
metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java	244
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java	409
metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentReplicas.java	126
metadata/src/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java	59
metadata/src/main/java/org/apache/kafka/controller/PeriodicTask.java	52
metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java	171
metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskFlag.java	4
metadata/src/main/java/org/apache/kafka/controller/ProducerIdControlManager.java	85
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java	1654
metadata/src/main/java/org/apache/kafka/controller/QuorumFeatures.java	101
metadata/src/main/java/org/apache/kafka/controller/RaftClientKRaftVersionAccessor.java	15
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java	1975
metadata/src/main/java/org/apache/kafka/controller/ResultOrError.java	59
metadata/src/main/java/org/apache/kafka/controller/ScramControlManager.java	290
metadata/src/main/java/org/apache/kafka/controller/errors/ControllerExceptions.java	30
metadata/src/main/java/org/apache/kafka/controller/errors/EventHandlerExceptionInfo.java	151
metadata/src/main/java/org/apache/kafka/controller/errors/PeriodicControlTaskException.java	6
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetrics.java	189
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsPublisher.java	117
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetricsChanges.java	132
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java	190
metadata/src/main/java/org/apache/kafka/image/AclsDelta.java	71
metadata/src/main/java/org/apache/kafka/image/AclsImage.java	41
metadata/src/main/java/org/apache/kafka/image/ClientQuotaDelta.java	49
metadata/src/main/java/org/apache/kafka/image/ClientQuotaImage.java	80
metadata/src/main/java/org/apache/kafka/image/ClientQuotasDelta.java	67
metadata/src/main/java/org/apache/kafka/image/ClientQuotasImage.java	152
metadata/src/main/java/org/apache/kafka/image/ClusterDelta.java	162
metadata/src/main/java/org/apache/kafka/image/ClusterImage.java	70
metadata/src/main/java/org/apache/kafka/image/ConfigurationDelta.java	54
metadata/src/main/java/org/apache/kafka/image/ConfigurationImage.java	64
metadata/src/main/java/org/apache/kafka/image/ConfigurationsDelta.java	79
metadata/src/main/java/org/apache/kafka/image/ConfigurationsImage.java	60
metadata/src/main/java/org/apache/kafka/image/DelegationTokenDelta.java	62
metadata/src/main/java/org/apache/kafka/image/DelegationTokenImage.java	51
metadata/src/main/java/org/apache/kafka/image/FeaturesDelta.java	83
metadata/src/main/java/org/apache/kafka/image/FeaturesImage.java	77
metadata/src/main/java/org/apache/kafka/image/LocalReplicaChanges.java	78
metadata/src/main/java/org/apache/kafka/image/MetadataDelta.java	367
metadata/src/main/java/org/apache/kafka/image/MetadataImage.java	144
metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java	65
metadata/src/main/java/org/apache/kafka/image/MetadataVersionChange.java	45
metadata/src/main/java/org/apache/kafka/image/MetadataVersionChangeException.java	13
metadata/src/main/java/org/apache/kafka/image/ProducerIdsDelta.java	29
metadata/src/main/java/org/apache/kafka/image/ProducerIdsImage.java	40
metadata/src/main/java/org/apache/kafka/image/ScramDelta.java	75
metadata/src/main/java/org/apache/kafka/image/ScramImage.java	119
metadata/src/main/java/org/apache/kafka/image/TopicDelta.java	153
metadata/src/main/java/org/apache/kafka/image/TopicImage.java	56
metadata/src/main/java/org/apache/kafka/image/TopicsDelta.java	174
metadata/src/main/java/org/apache/kafka/image/TopicsImage.java	72
metadata/src/main/java/org/apache/kafka/image/loader/LoaderManifest.java	6
metadata/src/main/java/org/apache/kafka/image/loader/LoaderManifestType.java	5
metadata/src/main/java/org/apache/kafka/image/loader/LogDeltaManifest.java	121
metadata/src/main/java/org/apache/kafka/image/loader/MetadataBatchLoader.java	196
metadata/src/main/java/org/apache/kafka/image/loader/MetadataLoader.java	414
metadata/src/main/java/org/apache/kafka/image/loader/SnapshotManifest.java	45
metadata/src/main/java/org/apache/kafka/image/loader/metrics/MetadataLoaderMetrics.java	99
metadata/src/main/java/org/apache/kafka/image/node/AclsImageByIdNode.java	33
metadata/src/main/java/org/apache/kafka/image/node/AclsImageNode.java	23
metadata/src/main/java/org/apache/kafka/image/node/ClientQuotaImageNode.java	19
metadata/src/main/java/org/apache/kafka/image/node/ClientQuotasImageNode.java	122
metadata/src/main/java/org/apache/kafka/image/node/ClusterImageBrokersNode.java	31
metadata/src/main/java/org/apache/kafka/image/node/ClusterImageControllersNode.java	31
metadata/src/main/java/org/apache/kafka/image/node/ClusterImageNode.java	25
metadata/src/main/java/org/apache/kafka/image/node/ConfigurationImageNode.java	34
metadata/src/main/java/org/apache/kafka/image/node/ConfigurationsImageNode.java	48
metadata/src/main/java/org/apache/kafka/image/node/DelegationTokenDataNode.java	64
metadata/src/main/java/org/apache/kafka/image/node/DelegationTokenImageNode.java	21
metadata/src/main/java/org/apache/kafka/image/node/FeaturesImageNode.java	36
metadata/src/main/java/org/apache/kafka/image/node/MetadataImageNode.java	35
metadata/src/main/java/org/apache/kafka/image/node/MetadataLeafNode.java	16
metadata/src/main/java/org/apache/kafka/image/node/MetadataNode.java	33
metadata/src/main/java/org/apache/kafka/image/node/ProducerIdsImageNode.java	23
metadata/src/main/java/org/apache/kafka/image/node/ProvenanceNode.java	26
metadata/src/main/java/org/apache/kafka/image/node/ScramCredentialDataNode.java	49
metadata/src/main/java/org/apache/kafka/image/node/ScramImageNode.java	31
metadata/src/main/java/org/apache/kafka/image/node/ScramMechanismNode.java	20
metadata/src/main/java/org/apache/kafka/image/node/TopicImageNode.java	39
metadata/src/main/java/org/apache/kafka/image/node/TopicsImageByIdNode.java	33
metadata/src/main/java/org/apache/kafka/image/node/TopicsImageByNameNode.java	21
metadata/src/main/java/org/apache/kafka/image/node/TopicsImageNode.java	25
metadata/src/main/java/org/apache/kafka/image/node/printer/MetadataNodePrinter.java	9
metadata/src/main/java/org/apache/kafka/image/node/printer/MetadataNodeRedactionCriteria.java	56
metadata/src/main/java/org/apache/kafka/image/node/printer/NodeStringifier.java	41
metadata/src/main/java/org/apache/kafka/image/publisher/BrokerRegistrationTracker.java	74
metadata/src/main/java/org/apache/kafka/image/publisher/ControllerRegistrationsPublisher.java	52
metadata/src/main/java/org/apache/kafka/image/publisher/MetadataPublisher.java	15
metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java	104
metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotGenerator.java	193
metadata/src/main/java/org/apache/kafka/image/publisher/metrics/SnapshotEmitterMetrics.java	65
metadata/src/main/java/org/apache/kafka/image/writer/ImageReWriter.java	29
metadata/src/main/java/org/apache/kafka/image/writer/ImageWriter.java	13
metadata/src/main/java/org/apache/kafka/image/writer/ImageWriterClosedException.java	7
metadata/src/main/java/org/apache/kafka/image/writer/ImageWriterOptions.java	62
metadata/src/main/java/org/apache/kafka/image/writer/RaftSnapshotWriter.java	47
metadata/src/main/java/org/apache/kafka/image/writer/RecordListWriter.java	24
metadata/src/main/java/org/apache/kafka/image/writer/UnwritableMetadataException.java	22
metadata/src/main/java/org/apache/kafka/metadata/BrokerHeartbeatReply.java	49
metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java	333
metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistrationFencingChange.java	29
metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistrationInControlledShutdownChange.java	28
metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistrationReply.java	24
metadata/src/main/java/org/apache/kafka/metadata/BrokerState.java	32
metadata/src/main/java/org/apache/kafka/metadata/ConfigRepository.java	16
metadata/src/main/java/org/apache/kafka/metadata/ControllerRegistration.java	187
metadata/src/main/java/org/apache/kafka/metadata/DelegationTokenData.java	58
metadata/src/main/java/org/apache/kafka/metadata/FinalizedControllerFeatures.java	45
metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java	209
metadata/src/main/java/org/apache/kafka/metadata/LeaderAndIsr.java	109
metadata/src/main/java/org/apache/kafka/metadata/LeaderConstants.java	5
metadata/src/main/java/org/apache/kafka/metadata/LeaderRecoveryState.java	33
metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java	261
metadata/src/main/java/org/apache/kafka/metadata/MetadataCache.java	135
metadata/src/main/java/org/apache/kafka/metadata/MetadataRecordSerde.java	11
metadata/src/main/java/org/apache/kafka/metadata/OptionalStringComparator.java	19
metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java	404
metadata/src/main/java/org/apache/kafka/metadata/Replicas.java	131
metadata/src/main/java/org/apache/kafka/metadata/ScramCredentialData.java	87
metadata/src/main/java/org/apache/kafka/metadata/VersionRange.java	45
metadata/src/main/java/org/apache/kafka/metadata/authorizer/AclCache.java	64
metadata/src/main/java/org/apache/kafka/metadata/authorizer/AclMutator.java	18
metadata/src/main/java/org/apache/kafka/metadata/authorizer/ClusterMetadataAuthorizer.java	83
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAcl.java	148
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAclRecordIterator.java	33
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAclWithId.java	56
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java	194
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java	427
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java	80
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java	145
metadata/src/main/java/org/apache/kafka/metadata/placement/ClusterDescriber.java	9
metadata/src/main/java/org/apache/kafka/metadata/placement/DefaultDirProvider.java	6
metadata/src/main/java/org/apache/kafka/metadata/placement/PartitionAssignment.java	36
metadata/src/main/java/org/apache/kafka/metadata/placement/PlacementSpec.java	50
metadata/src/main/java/org/apache/kafka/metadata/placement/ReplicaPlacer.java	10
metadata/src/main/java/org/apache/kafka/metadata/placement/StripedReplicaPlacer.java	213
metadata/src/main/java/org/apache/kafka/metadata/placement/TopicAssignment.java	27
metadata/src/main/java/org/apache/kafka/metadata/placement/UsableBroker.java	43
metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java	184
metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsemble.java	396
metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesVersion.java	41
metadata/src/main/java/org/apache/kafka/metadata/properties/PropertiesUtils.java	60
metadata/src/main/java/org/apache/kafka/metadata/publisher/AclPublisher.java	73
metadata/src/main/java/org/apache/kafka/metadata/publisher/FeaturesPublisher.java	42
metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java	390
metadata/src/main/java/org/apache/kafka/metadata/storage/FormatterException.java	9
metadata/src/main/java/org/apache/kafka/metadata/storage/ScramParser.java	225
metadata/src/main/java/org/apache/kafka/metadata/util/BatchFileReader.java	145
metadata/src/main/java/org/apache/kafka/metadata/util/BatchFileWriter.java	80
metadata/src/main/java/org/apache/kafka/metadata/util/RecordRedactor.java	38
metadata/src/main/java/org/apache/kafka/metadata/util/SnapshotFileReader.java	172