Path	Lines of Code
core/src/main/java/kafka/docker/Log4jConfiguration.java	164
core/src/main/java/kafka/server/ClientRequestQuotaManager.java	74
core/src/main/java/kafka/server/MetadataVersionConfigValidator.java	46
core/src/main/java/kafka/server/NetworkUtils.java	67
core/src/main/java/kafka/server/QuotaFactory.java	141
core/src/main/java/kafka/server/ReplicaQuota.java	7
core/src/main/java/kafka/server/ReplicationQuotaManager.java	103
core/src/main/java/kafka/server/TierStateMachine.java	169
core/src/main/java/kafka/server/builders/KafkaApisBuilder.java	188
core/src/main/java/kafka/server/builders/LogManagerBuilder.java	135
core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java	101
core/src/main/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandler.java	97
core/src/main/java/kafka/server/logger/RuntimeLoggerManager.java	118
core/src/main/java/kafka/server/share/DelayedShareFetch.java	650
core/src/main/java/kafka/server/share/PendingRemoteFetches.java	56
core/src/main/java/kafka/server/share/ShareCoordinatorMetadataCacheHelperImpl.java	83
core/src/main/java/kafka/server/share/ShareFetchUtils.java	175
core/src/main/java/kafka/server/share/SharePartition.java	2060
core/src/main/java/kafka/server/share/SharePartitionManager.java	549
core/src/main/scala/kafka/Kafka.scala	75
core/src/main/scala/kafka/admin/ConfigCommand.scala	582
core/src/main/scala/kafka/cluster/Partition.scala	1320
core/src/main/scala/kafka/cluster/Replica.scala	119
core/src/main/scala/kafka/controller/StateChangeLogger.scala	16
core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala	181
core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala	127
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	818
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	78
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	368
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	141
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	418
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	647
core/src/main/scala/kafka/docker/KafkaDockerWrapper.scala	279
core/src/main/scala/kafka/log/LogManager.scala	1098
core/src/main/scala/kafka/log/package.html	4
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	52
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala	12
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala	39
core/src/main/scala/kafka/network/RequestChannel.scala	372
core/src/main/scala/kafka/network/SocketServer.scala	1249
core/src/main/scala/kafka/network/package.html	11
core/src/main/scala/kafka/raft/DefaultExternalKRaftMetrics.scala	13
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala	548
core/src/main/scala/kafka/raft/RaftManager.scala	244
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	184
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	680
core/src/main/scala/kafka/server/AclApis.scala	137
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala	243
core/src/main/scala/kafka/server/AlterPartitionManager.scala	215
core/src/main/scala/kafka/server/AuthHelper.scala	144
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala	201
core/src/main/scala/kafka/server/BrokerBlockingSender.scala	103
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala	408
core/src/main/scala/kafka/server/BrokerServer.scala	642
core/src/main/scala/kafka/server/ClientQuotaManager.scala	405
core/src/main/scala/kafka/server/ConfigAdminManager.scala	322
core/src/main/scala/kafka/server/ConfigHandler.scala	122
core/src/main/scala/kafka/server/ConfigHelper.scala	279
core/src/main/scala/kafka/server/ControllerApis.scala	975
core/src/main/scala/kafka/server/ControllerConfigurationValidator.scala	105
core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala	151
core/src/main/scala/kafka/server/ControllerRegistrationManager.scala	203
core/src/main/scala/kafka/server/ControllerServer.scala	379
core/src/main/scala/kafka/server/DelayedFetch.scala	128
core/src/main/scala/kafka/server/DelayedProduce.scala	88
core/src/main/scala/kafka/server/DelayedRemoteFetch.scala	88
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	851
core/src/main/scala/kafka/server/DynamicConfig.scala	32
core/src/main/scala/kafka/server/EnvelopeUtils.scala	105
core/src/main/scala/kafka/server/FetchSession.scala	580
core/src/main/scala/kafka/server/ForwardingManager.scala	146
core/src/main/scala/kafka/server/KafkaApis.scala	3343
core/src/main/scala/kafka/server/KafkaBroker.scala	82
core/src/main/scala/kafka/server/KafkaConfig.scala	607
core/src/main/scala/kafka/server/KafkaRaftServer.scala	134
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	168
core/src/main/scala/kafka/server/LeaderEndPoint.scala	23
core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala	182
core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala	273
core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala	167
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	39
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	156
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	37
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	120
core/src/main/scala/kafka/server/ReplicaManager.scala	2203
core/src/main/scala/kafka/server/RequestHandlerHelper.scala	115
core/src/main/scala/kafka/server/Server.scala	55
core/src/main/scala/kafka/server/SharedServer.scala	297
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala	246
core/src/main/scala/kafka/server/metadata/ClientQuotaMetadataManager.scala	146
core/src/main/scala/kafka/server/metadata/DelegationTokenPublisher.scala	57
core/src/main/scala/kafka/server/metadata/DynamicClientQuotaPublisher.scala	36
core/src/main/scala/kafka/server/metadata/DynamicConfigPublisher.scala	107
core/src/main/scala/kafka/server/metadata/DynamicTopicClusterQuotaPublisher.scala	48
core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala	379
core/src/main/scala/kafka/server/metadata/KRaftMetadataCachePublisher.scala	16
core/src/main/scala/kafka/server/metadata/ScramPublisher.scala	47
core/src/main/scala/kafka/server/package.html	1
core/src/main/scala/kafka/tools/DumpLogSegments.scala	566
core/src/main/scala/kafka/tools/StorageTool.scala	401
core/src/main/scala/kafka/tools/TerseFailure.scala	5
core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala	81
core/src/main/scala/kafka/tools/TestRaftServer.scala	397
core/src/main/scala/kafka/utils/Annotations.scala	5
core/src/main/scala/kafka/utils/CoreUtils.scala	116
core/src/main/scala/kafka/utils/Implicits.scala	12
core/src/main/scala/kafka/utils/Logging.scala	43
core/src/main/scala/kafka/utils/LoggingController.scala	103
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37
core/src/main/scala/kafka/utils/VerifiableProperties.scala	112