Path	Lines of Code
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/LogSegmentData.java	75
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadata.java	17
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java	38
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentId.java	43
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java	203
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadataUpdate.java	61
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentState.java	41
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemotePartitionDeleteMetadata.java	48
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemotePartitionDeleteState.java	39
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteResourceNotFoundException.java	13
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteStorageException.java	13
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteStorageManager.java	27
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteStorageMetrics.java	122
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/package-info.java	1
storage/src/main/java/org/apache/kafka/server/log/remote/TopicPartitionLog.java	8
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ClassLoaderAwareRemoteLogMetadataManager.java	105
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerManager.java	90
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java	350
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ProducerManager.java	59
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogLeaderEpochState.java	88
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java	184
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataTopicPartitioner.java	33
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogSegmentMetadataSnapshot.java	131
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemotePartitionMetadataEventHandler.java	30
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemotePartitionMetadataStore.java	125
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java	442
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerConfig.java	191
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java	84
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataTransform.java	7
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataSnapshotTransform.java	54
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransform.java	74
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataUpdateTransform.java	39
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemotePartitionDeleteMetadataTransform.java	32
storage/src/main/java/org/apache/kafka/server/log/remote/quota/RLMQuotaManager.java	83
storage/src/main/java/org/apache/kafka/server/log/remote/quota/RLMQuotaManagerConfig.java	29
storage/src/main/java/org/apache/kafka/server/log/remote/quota/RLMQuotaMetrics.java	21
storage/src/main/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManager.java	64
storage/src/main/java/org/apache/kafka/server/log/remote/storage/CustomMetadataSizeLimitExceededException.java	3
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java	1657
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java	414
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogOffsetReader.java	53
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogReader.java	59
storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java	146
storage/src/main/java/org/apache/kafka/server/purgatory/ListOffsetsPartitionStatus.java	84
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/CheckpointFileWithFailureHandler.java	55
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/CleanShutdownFileHandler.java	69
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/LazyOffsetCheckpoints.java	33
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/LeaderEpochCheckpointFile.java	41
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/OffsetCheckpointFile.java	61
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/OffsetCheckpoints.java	6
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/PartitionMetadata.java	19
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/PartitionMetadataFile.java	101
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/PartitionMetadataReadBuffer.java	53
storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java	341
storage/src/main/java/org/apache/kafka/storage/internals/log/AbortedTxn.java	81
storage/src/main/java/org/apache/kafka/storage/internals/log/AbstractIndex.java	305
storage/src/main/java/org/apache/kafka/storage/internals/log/AppendOrigin.java	7
storage/src/main/java/org/apache/kafka/storage/internals/log/AsyncOffsetReadFutureHolder.java	5
storage/src/main/java/org/apache/kafka/storage/internals/log/AsyncOffsetReader.java	17
storage/src/main/java/org/apache/kafka/storage/internals/log/BatchMetadata.java	52
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanedTransactionMetadata.java	88
storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java	462
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanerConfig.java	110
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanerStats.java	82
storage/src/main/java/org/apache/kafka/storage/internals/log/CompletedTxn.java	39
storage/src/main/java/org/apache/kafka/storage/internals/log/CorruptIndexException.java	6
storage/src/main/java/org/apache/kafka/storage/internals/log/CorruptSnapshotException.java	7
storage/src/main/java/org/apache/kafka/storage/internals/log/EpochEntry.java	29
storage/src/main/java/org/apache/kafka/storage/internals/log/FetchDataInfo.java	37
storage/src/main/java/org/apache/kafka/storage/internals/log/IndexEntry.java	5
storage/src/main/java/org/apache/kafka/storage/internals/log/IndexOffsetOverflowException.java	7
storage/src/main/java/org/apache/kafka/storage/internals/log/IndexSearchType.java	4
storage/src/main/java/org/apache/kafka/storage/internals/log/LastRecord.java	31
storage/src/main/java/org/apache/kafka/storage/internals/log/LazyIndex.java	178
storage/src/main/java/org/apache/kafka/storage/internals/log/LeaderHwChange.java	6
storage/src/main/java/org/apache/kafka/storage/internals/log/LoadedLogOffsets.java	42
storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java	666
storage/src/main/java/org/apache/kafka/storage/internals/log/LogAppendInfo.java	152
storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java	359
storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleanerManager.java	502
storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningAbortedException.java	3
storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningException.java	9
storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningState.java	41
storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java	540
storage/src/main/java/org/apache/kafka/storage/internals/log/LogDirFailureChannel.java	29
storage/src/main/java/org/apache/kafka/storage/internals/log/LogFileUtils.java	65
storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java	374
storage/src/main/java/org/apache/kafka/storage/internals/log/LogManager.java	52
storage/src/main/java/org/apache/kafka/storage/internals/log/LogMetricNames.java	9
storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetMetadata.java	60
storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetSnapshot.java	44
storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetsListener.java	5
storage/src/main/java/org/apache/kafka/storage/internals/log/LogReadInfo.java	35
storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegment.java	531
storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegmentOffsetOverflowException.java	11
storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java	135
storage/src/main/java/org/apache/kafka/storage/internals/log/LogStartOffsetIncrementReason.java	15
storage/src/main/java/org/apache/kafka/storage/internals/log/LogToClean.java	96
storage/src/main/java/org/apache/kafka/storage/internals/log/LogTruncation.java	16
storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java	460
storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetIndex.java	144
storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetMap.java	15
storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetPosition.java	40
storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetResultHolder.java	102
storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetsOutOfOrderException.java	6
storage/src/main/java/org/apache/kafka/storage/internals/log/PreCleanStats.java	27
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerAppendInfo.java	173
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateEntry.java	124
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java	444
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManagerConfig.java	21
storage/src/main/java/org/apache/kafka/storage/internals/log/RecordValidationException.java	20
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java	513
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteLogReadResult.java	10
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteStorageFetchInfo.java	29
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteStorageThreadPool.java	48
storage/src/main/java/org/apache/kafka/storage/internals/log/RollParams.java	33
storage/src/main/java/org/apache/kafka/storage/internals/log/SegmentDeletionReason.java	6
storage/src/main/java/org/apache/kafka/storage/internals/log/SkimpyOffsetMap.java	121
storage/src/main/java/org/apache/kafka/storage/internals/log/SnapshotFile.java	51
storage/src/main/java/org/apache/kafka/storage/internals/log/StorageAction.java	5
storage/src/main/java/org/apache/kafka/storage/internals/log/ThreadShutdownException.java	3
storage/src/main/java/org/apache/kafka/storage/internals/log/ThrottledReplicaListValidator.java	26
storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java	165
storage/src/main/java/org/apache/kafka/storage/internals/log/TimestampOffset.java	40
storage/src/main/java/org/apache/kafka/storage/internals/log/TransactionIndex.java	179
storage/src/main/java/org/apache/kafka/storage/internals/log/TxnIndexSearchResult.java	11
storage/src/main/java/org/apache/kafka/storage/internals/log/TxnMetadata.java	30
storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java	1748
storage/src/main/java/org/apache/kafka/storage/internals/log/VerificationGuard.java	34
storage/src/main/java/org/apache/kafka/storage/internals/log/VerificationStateEntry.java	38
storage/src/main/java/org/apache/kafka/storage/internals/utils/Throttler.java	59
storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java	327
storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicStats.java	196