Path	Lines of Code
server/src/main/java/org/apache/kafka/network/ConnectionQuotaEntity.java	51
server/src/main/java/org/apache/kafka/network/ConnectionThrottledException.java	12
server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java	794
server/src/main/java/org/apache/kafka/network/Session.java	14
server/src/main/java/org/apache/kafka/network/SocketServerConfigs.java	185
server/src/main/java/org/apache/kafka/network/TooManyConnectionsException.java	12
server/src/main/java/org/apache/kafka/network/metrics/RequestChannelMetrics.java	35
server/src/main/java/org/apache/kafka/network/metrics/RequestMetrics.java	165
server/src/main/java/org/apache/kafka/security/CredentialProvider.java	32
server/src/main/java/org/apache/kafka/security/authorizer/AclEntry.java	66
server/src/main/java/org/apache/kafka/security/authorizer/AuthorizerUtils.java	17
server/src/main/java/org/apache/kafka/server/ActionQueue.java	5
server/src/main/java/org/apache/kafka/server/ApiVersionManager.java	18
server/src/main/java/org/apache/kafka/server/Assignment.java	58
server/src/main/java/org/apache/kafka/server/AssignmentsManager.java	367
server/src/main/java/org/apache/kafka/server/AssignmentsManagerDeadlineFunction.java	41
server/src/main/java/org/apache/kafka/server/BrokerFeatures.java	88
server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java	490
server/src/main/java/org/apache/kafka/server/DefaultApiVersionManager.java	67
server/src/main/java/org/apache/kafka/server/DelayedActionQueue.java	25
server/src/main/java/org/apache/kafka/server/DelegationTokenManager.java	91
server/src/main/java/org/apache/kafka/server/DynamicThreadPool.java	44
server/src/main/java/org/apache/kafka/server/ProcessRole.java	13
server/src/main/java/org/apache/kafka/server/ServerSocketFactory.java	40
server/src/main/java/org/apache/kafka/server/SimpleApiVersionManager.java	49
server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java	58
server/src/main/java/org/apache/kafka/server/config/ClientQuotaManagerConfig.java	15
server/src/main/java/org/apache/kafka/server/config/DelegationTokenManagerConfigs.java	56
server/src/main/java/org/apache/kafka/server/config/DynamicProducerStateManagerConfig.java	45
server/src/main/java/org/apache/kafka/server/config/KRaftConfigs.java	52
server/src/main/java/org/apache/kafka/server/config/ReplicationConfigs.java	121
server/src/main/java/org/apache/kafka/server/config/ReplicationQuotaManagerConfig.java	18
server/src/main/java/org/apache/kafka/server/metrics/BrokerServerMetrics.java	135
server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsConfigs.java	122
server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsInstance.java	93
server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsInstanceMetadata.java	37
server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsReceiverPlugin.java	28
server/src/main/java/org/apache/kafka/server/metrics/DefaultClientTelemetryPayload.java	33
server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java	88
server/src/main/java/org/apache/kafka/server/metrics/LinuxIoMetricsCollector.java	70
server/src/main/java/org/apache/kafka/server/metrics/MetricConfigs.java	48
server/src/main/java/org/apache/kafka/server/package-info.java	1
server/src/main/java/org/apache/kafka/server/purgatory/DelayedDeleteRecords.java	60
server/src/main/java/org/apache/kafka/server/purgatory/DelayedFuture.java	40
server/src/main/java/org/apache/kafka/server/purgatory/DelayedFuturePurgatory.java	45
server/src/main/java/org/apache/kafka/server/purgatory/DeleteRecordsPartitionStatus.java	31
server/src/main/java/org/apache/kafka/server/quota/ThrottleCallback.java	5
server/src/main/java/org/apache/kafka/server/quota/ThrottledChannel.java	36
server/src/main/java/org/apache/kafka/server/share/CachedSharePartition.java	99
server/src/main/java/org/apache/kafka/server/share/ErroneousAndValidPartitionData.java	39
server/src/main/java/org/apache/kafka/server/share/acknowledge/ShareAcknowledgementBatch.java	16
server/src/main/java/org/apache/kafka/server/share/context/FinalContext.java	34
server/src/main/java/org/apache/kafka/server/share/context/ShareFetchContext.java	25
server/src/main/java/org/apache/kafka/server/share/context/ShareSessionContext.java	173
server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java	39
server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKey.java	4
server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchPartitionKey.java	31
server/src/main/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategy.java	39
server/src/main/java/org/apache/kafka/server/share/fetch/PartitionRotateStrategy.java	37
server/src/main/java/org/apache/kafka/server/share/fetch/ShareAcquiredRecords.java	29
server/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java	117
server/src/main/java/org/apache/kafka/server/share/fetch/ShareFetchPartitionData.java	9
server/src/main/java/org/apache/kafka/server/share/metrics/ShareGroupMetrics.java	90
server/src/main/java/org/apache/kafka/server/share/metrics/SharePartitionMetrics.java	97
server/src/main/java/org/apache/kafka/server/share/session/ShareSession.java	89
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java	91
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionKey.java	35