Path	Lines of Code
server-common/src/main/java/org/apache/kafka/common/ClientIdAndBroker.java	15
server-common/src/main/java/org/apache/kafka/common/DirectoryId.java	60
server-common/src/main/java/org/apache/kafka/config/BrokerReconfigurable.java	8
server-common/src/main/java/org/apache/kafka/deferred/DeferredEvent.java	4
server-common/src/main/java/org/apache/kafka/deferred/DeferredEventQueue.java	69
server-common/src/main/java/org/apache/kafka/metadata/AssignmentsHelper.java	80
server-common/src/main/java/org/apache/kafka/queue/EventQueue.java	83
server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java	383
server-common/src/main/java/org/apache/kafka/server/common/ApiMessageAndVersion.java	33
server-common/src/main/java/org/apache/kafka/server/common/CheckpointFile.java	137
server-common/src/main/java/org/apache/kafka/server/common/ControllerRequestCompletionHandler.java	5
server-common/src/main/java/org/apache/kafka/server/common/DirectoryEventHandler.java	10
server-common/src/main/java/org/apache/kafka/server/common/EligibleLeaderReplicasVersion.java	46
server-common/src/main/java/org/apache/kafka/server/common/Feature.java	186
server-common/src/main/java/org/apache/kafka/server/common/FeatureVersion.java	8
server-common/src/main/java/org/apache/kafka/server/common/FinalizedFeatures.java	44
server-common/src/main/java/org/apache/kafka/server/common/GroupVersion.java	49
server-common/src/main/java/org/apache/kafka/server/common/KRaftVersion.java	83
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java	236
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersionValidator.java	20
server-common/src/main/java/org/apache/kafka/server/common/NodeToControllerChannelManager.java	14
server-common/src/main/java/org/apache/kafka/server/common/OffsetAndEpoch.java	9
server-common/src/main/java/org/apache/kafka/server/common/ProducerIdsBlock.java	59
server-common/src/main/java/org/apache/kafka/server/common/RequestLocal.java	38
server-common/src/main/java/org/apache/kafka/server/common/ShareVersion.java	49
server-common/src/main/java/org/apache/kafka/server/common/StopPartition.java	38
server-common/src/main/java/org/apache/kafka/server/common/StreamsVersion.java	46
server-common/src/main/java/org/apache/kafka/server/common/TestFeatureVersion.java	30
server-common/src/main/java/org/apache/kafka/server/common/TopicIdPartition.java	11
server-common/src/main/java/org/apache/kafka/server/common/TopicOptionalIdPartition.java	51
server-common/src/main/java/org/apache/kafka/server/common/TransactionVersion.java	54
server-common/src/main/java/org/apache/kafka/server/common/UnitTestFeatureVersion.java	244
server-common/src/main/java/org/apache/kafka/server/common/serialization/AbstractApiMessageSerde.java	72
server-common/src/main/java/org/apache/kafka/server/common/serialization/BytesApiMessageSerde.java	27
server-common/src/main/java/org/apache/kafka/server/common/serialization/MetadataParseException.java	13
server-common/src/main/java/org/apache/kafka/server/common/serialization/RecordSerde.java	9
server-common/src/main/java/org/apache/kafka/server/config/ConfigSynonym.java	44
server-common/src/main/java/org/apache/kafka/server/config/ConfigType.java	17
server-common/src/main/java/org/apache/kafka/server/config/QuotaConfig.java	177
server-common/src/main/java/org/apache/kafka/server/config/ServerConfigs.java	102
server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java	110
server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java	86
server-common/src/main/java/org/apache/kafka/server/fault/FaultHandler.java	7
server-common/src/main/java/org/apache/kafka/server/fault/FaultHandlerException.java	12
server-common/src/main/java/org/apache/kafka/server/fault/LoggingFaultHandler.java	29
server-common/src/main/java/org/apache/kafka/server/fault/ProcessTerminatingFaultHandler.java	49
server-common/src/main/java/org/apache/kafka/server/immutable/ImmutableMap.java	13
server-common/src/main/java/org/apache/kafka/server/immutable/ImmutableNavigableSet.java	13
server-common/src/main/java/org/apache/kafka/server/immutable/ImmutableSet.java	13
server-common/src/main/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableMap.java	144
server-common/src/main/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableNavigableSet.java	192
server-common/src/main/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableSet.java	124
server-common/src/main/java/org/apache/kafka/server/metrics/FilteringJmxReporter.java	32
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java	118
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java	132
server-common/src/main/java/org/apache/kafka/server/mutable/BoundedList.java	155
server-common/src/main/java/org/apache/kafka/server/mutable/BoundedListTooLongException.java	10
server-common/src/main/java/org/apache/kafka/server/network/BrokerEndPoint.java	2
server-common/src/main/java/org/apache/kafka/server/network/ConnectionDisconnectListener.java	4
server-common/src/main/java/org/apache/kafka/server/network/EndpointReadyFutures.java	152
server-common/src/main/java/org/apache/kafka/server/network/KafkaAuthorizerServerInfo.java	75
server-common/src/main/java/org/apache/kafka/server/purgatory/DelayedOperation.java	65
server-common/src/main/java/org/apache/kafka/server/purgatory/DelayedOperationKey.java	4
server-common/src/main/java/org/apache/kafka/server/purgatory/DelayedOperationPurgatory.java	254
server-common/src/main/java/org/apache/kafka/server/purgatory/TopicPartitionOperationKey.java	33
server-common/src/main/java/org/apache/kafka/server/quota/QuotaType.java	29
server-common/src/main/java/org/apache/kafka/server/quota/QuotaUtils.java	26
server-common/src/main/java/org/apache/kafka/server/quota/SensorAccess.java	35
server-common/src/main/java/org/apache/kafka/server/record/BrokerCompressionType.java	32
server-common/src/main/java/org/apache/kafka/server/share/SharePartitionKey.java	97
server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java	486
server-common/src/main/java/org/apache/kafka/server/share/persister/DeleteShareGroupStateParameters.java	48
server-common/src/main/java/org/apache/kafka/server/share/persister/DeleteShareGroupStateResult.java	35
server-common/src/main/java/org/apache/kafka/server/share/persister/GroupTopicPartitionData.java	55
server-common/src/main/java/org/apache/kafka/server/share/persister/InitializeShareGroupStateParameters.java	35
server-common/src/main/java/org/apache/kafka/server/share/persister/InitializeShareGroupStateResult.java	33
server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java	70
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionAllData.java	9
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionData.java	114
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionErrorData.java	5
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java	31
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionIdData.java	4
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionIdLeaderEpochData.java	4
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionInfoData.java	3
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateBatchData.java	8
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateData.java	5
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateErrorData.java	7
server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java	8
server-common/src/main/java/org/apache/kafka/server/share/persister/Persister.java	10
server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterParameters.java	3
server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterResult.java	3
server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateBatch.java	81
server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java	1156
server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateParameters.java	36
server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateResult.java	42
server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateSummaryParameters.java	43
server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateSummaryResult.java	35
server-common/src/main/java/org/apache/kafka/server/share/persister/ShareCoordinatorMetadataCacheHelper.java	9
server-common/src/main/java/org/apache/kafka/server/share/persister/TopicData.java	36
server-common/src/main/java/org/apache/kafka/server/share/persister/WriteShareGroupStateParameters.java	40
server-common/src/main/java/org/apache/kafka/server/share/persister/WriteShareGroupStateResult.java	33
server-common/src/main/java/org/apache/kafka/server/storage/log/FetchIsolation.java	20
server-common/src/main/java/org/apache/kafka/server/storage/log/FetchParams.java	95
server-common/src/main/java/org/apache/kafka/server/storage/log/FetchPartitionData.java	38
server-common/src/main/java/org/apache/kafka/server/storage/log/UnexpectedAppendOffsetException.java	10
server-common/src/main/java/org/apache/kafka/server/util/CommandDefaultOptions.java	21
server-common/src/main/java/org/apache/kafka/server/util/CommandLineUtils.java	164
server-common/src/main/java/org/apache/kafka/server/util/Csv.java	25
server-common/src/main/java/org/apache/kafka/server/util/Deadline.java	46
server-common/src/main/java/org/apache/kafka/server/util/FileLock.java	48
server-common/src/main/java/org/apache/kafka/server/util/FutureUtils.java	76
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java	202
server-common/src/main/java/org/apache/kafka/server/util/Json.java	47
server-common/src/main/java/org/apache/kafka/server/util/KafkaScheduler.java	137
server-common/src/main/java/org/apache/kafka/server/util/LockUtils.java	16
server-common/src/main/java/org/apache/kafka/server/util/RequestAndCompletionHandler.java	30
server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java	14
server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java	93
server-common/src/main/java/org/apache/kafka/server/util/ThroughputThrottler.java	67
server-common/src/main/java/org/apache/kafka/server/util/TranslatedValueMapView.java	76
server-common/src/main/java/org/apache/kafka/server/util/json/DecodeJson.java	93
server-common/src/main/java/org/apache/kafka/server/util/json/JsonArray.java	41
server-common/src/main/java/org/apache/kafka/server/util/json/JsonObject.java	53
server-common/src/main/java/org/apache/kafka/server/util/json/JsonValue.java	72
server-common/src/main/java/org/apache/kafka/server/util/timer/SystemTimer.java	84
server-common/src/main/java/org/apache/kafka/server/util/timer/SystemTimerReaper.java	49
server-common/src/main/java/org/apache/kafka/server/util/timer/Timer.java	6
server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTask.java	28
server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTaskEntry.java	28
server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTaskList.java	93
server-common/src/main/java/org/apache/kafka/server/util/timer/TimingWheel.java	68
server-common/src/main/java/org/apache/kafka/timeline/BaseHashTable.java	183
server-common/src/main/java/org/apache/kafka/timeline/Delta.java	4
server-common/src/main/java/org/apache/kafka/timeline/Revertable.java	5
server-common/src/main/java/org/apache/kafka/timeline/Snapshot.java	59
server-common/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java	199
server-common/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java	280
server-common/src/main/java/org/apache/kafka/timeline/TimelineHashMap.java	305
server-common/src/main/java/org/apache/kafka/timeline/TimelineHashSet.java	195
server-common/src/main/java/org/apache/kafka/timeline/TimelineInteger.java	78
server-common/src/main/java/org/apache/kafka/timeline/TimelineLong.java	78
server-common/src/main/java/org/apache/kafka/timeline/TimelineObject.java	80