Path	Lines of Code
core/src/main/java/kafka/log/remote/RemoteLogManager.java	1667
core/src/main/java/kafka/log/remote/RemoteLogOffsetReader.java	52
core/src/main/java/kafka/log/remote/RemoteLogReader.java	59
core/src/main/java/kafka/server/ClientRequestQuotaManager.java	68
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	118
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	167
core/src/main/java/kafka/server/builders/KafkaApisBuilder.java	179
core/src/main/java/kafka/server/builders/LogManagerBuilder.java	143
core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java	101
core/src/main/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandler.java	99
core/src/main/java/kafka/server/logger/RuntimeLoggerManager.java	118
core/src/main/java/kafka/server/share/DelayedShareFetch.java	319
core/src/main/java/kafka/server/share/ShareCoordinatorMetadataCacheHelperImpl.java	87
core/src/main/java/kafka/server/share/ShareFetchUtils.java	117
core/src/main/java/kafka/server/share/SharePartition.java	1802
core/src/main/java/kafka/server/share/SharePartitionManager.java	615
core/src/main/scala/kafka/Kafka.scala	75
core/src/main/scala/kafka/MetadataLogConfig.scala	29
core/src/main/scala/kafka/admin/ConfigCommand.scala	564
core/src/main/scala/kafka/cluster/Broker.scala	47
core/src/main/scala/kafka/cluster/EndPoint.scala	33
core/src/main/scala/kafka/cluster/Partition.scala	1310
core/src/main/scala/kafka/cluster/Replica.scala	120
core/src/main/scala/kafka/common/BrokerEndPointNotAvailableException.scala	4
core/src/main/scala/kafka/controller/StateChangeLogger.scala	16
core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala	186
core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala	131
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala	12
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala	50
core/src/main/scala/kafka/coordinator/group/DelayedRebalance.scala	10
core/src/main/scala/kafka/coordinator/group/DelayedSync.scala	18
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala	1482
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala	561
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala	564
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala	916
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala	81
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	806
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	93
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	366
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	141
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	417
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	631
core/src/main/scala/kafka/docker/KafkaDockerWrapper.scala	206
core/src/main/scala/kafka/log/LogCleaner.scala	759
core/src/main/scala/kafka/log/LogCleanerManager.scala	443
core/src/main/scala/kafka/log/LogManager.scala	1128
core/src/main/scala/kafka/log/UnifiedLog.scala	1321
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	38
core/src/main/scala/kafka/network/RequestChannel.scala	375
core/src/main/scala/kafka/network/SocketServer.scala	1254
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	543
core/src/main/scala/kafka/raft/RaftManager.scala	242
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	185
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	675
core/src/main/scala/kafka/server/AclApis.scala	132
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala	242
core/src/main/scala/kafka/server/AlterPartitionManager.scala	240
core/src/main/scala/kafka/server/ApiVersionManager.scala	121
core/src/main/scala/kafka/server/AuthHelper.scala	143
core/src/main/scala/kafka/server/AutoTopicCreationManager.scala	181
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	644
core/src/main/scala/kafka/server/ClientQuotaManager.scala	404
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	266
core/src/main/scala/kafka/server/ControllerApis.scala	977
core/src/main/scala/kafka/server/ControllerConfigurationValidator.scala	105
core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala	150
core/src/main/scala/kafka/server/ControllerRegistrationManager.scala	200
core/src/main/scala/kafka/server/ControllerServer.scala	366
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala	79
core/src/main/scala/kafka/server/DelayedElectLeader.scala	40
core/src/main/scala/kafka/server/DelayedFetch.scala	128
core/src/main/scala/kafka/server/DelayedFuture.scala	63
core/src/main/scala/kafka/server/DelayedProduce.scala	90
core/src/main/scala/kafka/server/DelayedRemoteFetch.scala	88
core/src/main/scala/kafka/server/DelayedRemoteListOffsets.scala	124
core/src/main/scala/kafka/server/DelegationTokenManager.scala	83
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	830
core/src/main/scala/kafka/server/DynamicConfig.scala	70
core/src/main/scala/kafka/server/EnvelopeUtils.scala	105
core/src/main/scala/kafka/server/FetchSession.scala	581
core/src/main/scala/kafka/server/ForwardingManager.scala	144
core/src/main/scala/kafka/server/ForwardingManagerMetrics.scala	60
core/src/main/scala/kafka/server/KafkaApis.scala	2916
core/src/main/scala/kafka/server/KafkaBroker.scala	82
core/src/main/scala/kafka/server/KafkaConfig.scala	637
core/src/main/scala/kafka/server/KafkaRaftServer.scala	136
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	169
core/src/main/scala/kafka/server/LeaderEndPoint.scala	23
core/src/main/scala/kafka/server/ListOffsetsPartitionStatus.scala	26
core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala	184
core/src/main/scala/kafka/server/MetadataCache.scala	60
core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala	273
core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala	168
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	39
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	152
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	37
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	126
core/src/main/scala/kafka/server/ReplicaManager.scala	2100
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/AclPublisher.scala	61
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala	244
core/src/main/scala/kafka/server/metadata/ClientQuotaMetadataManager.scala	129
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/KRaftMetadataCache.scala	419
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	568
core/src/main/scala/kafka/tools/StorageTool.scala	404
core/src/main/scala/kafka/tools/TerseFailure.scala	4
core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala	80
core/src/main/scala/kafka/tools/TestRaftServer.scala	396
core/src/main/scala/kafka/utils/Annotations.scala	5
core/src/main/scala/kafka/utils/CoreUtils.scala	152
core/src/main/scala/kafka/utils/Implicits.scala	12
core/src/main/scala/kafka/utils/Log4jController.scala	71
core/src/main/scala/kafka/utils/Logging.scala	41
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37
core/src/main/scala/kafka/utils/Pool.scala	38
core/src/main/scala/kafka/utils/VerifiableProperties.scala	112
core/src/main/scala/kafka/utils/json/DecodeJson.scala	60
core/src/main/scala/kafka/utils/json/JsonArray.scala	7
core/src/main/scala/kafka/utils/json/JsonObject.scala	13
core/src/main/scala/kafka/utils/json/JsonValue.scala	40