6,843 results
« Page 48 of 69 »
Detected license expression: apache-2.0
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/AsyncOffsetReader.java scanned file 2.2 KB AsyncOffsetReader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/AsyncOffsetReadFutureHolder.java scanned file 1.2 KB AsyncOffsetReadFutureHolder.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/BatchMetadata.java scanned file 1.5 KB BatchMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CleanedTransactionMetadata.java scanned file 6.4 KB CleanedTransactionMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CleanerConfig.java scanned file 11.2 KB CleanerConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java scanned file 36.4 KB Cleaner.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CleanerStats.java scanned file 3.4 KB CleanerStats.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CompletedTxn.java scanned file 1.4 KB CompletedTxn.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CorruptIndexException.java scanned file 993 bytes CorruptIndexException.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CorruptSnapshotException.java scanned file 1.0 KB CorruptSnapshotException.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/EpochEntry.java scanned file 970 bytes EpochEntry.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/FetchDataInfo.java scanned file 2.7 KB FetchDataInfo.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/FetchPartitionStatus.java scanned file 1.1 KB FetchPartitionStatus.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/IndexEntry.java scanned file 924 bytes IndexEntry.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/IndexOffsetOverflowException.java scanned file 1.1 KB IndexOffsetOverflowException.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/IndexSearchType.java scanned file 895 bytes IndexSearchType.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LastRecord.java scanned file 1.2 KB LastRecord.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LazyIndex.java scanned file 7.2 KB LazyIndex.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LeaderHwChange.java scanned file 913 bytes LeaderHwChange.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LoadedLogOffsets.java scanned file 1.4 KB LoadedLogOffsets.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java scanned file 53.0 KB LocalLog.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogAppendInfo.java scanned file 10.9 KB LogAppendInfo.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java scanned file 28.9 KB LogCleaner.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleanerManager.java scanned file 37.5 KB LogCleanerManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningAbortedException.java scanned file 989 bytes LogCleaningAbortedException.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningException.java scanned file 1.3 KB LogCleaningException.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningState.java scanned file 2.3 KB LogCleaningState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java scanned file 39.9 KB LogConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogDirFailureChannel.java scanned file 3.3 KB LogDirFailureChannel.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogFileUtils.java scanned file 7.9 KB LogFileUtils.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java scanned file 28.1 KB LogLoader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogManager.java scanned file 4.1 KB LogManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogMetricNames.java scanned file 1.2 KB LogMetricNames.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetMetadata.java scanned file 4.2 KB LogOffsetMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetsListener.java scanned file 1.4 KB LogOffsetsListener.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetSnapshot.java scanned file 1.3 KB LogOffsetSnapshot.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogReadInfo.java scanned file 1.2 KB LogReadInfo.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogReadResult.java scanned file 3.7 KB LogReadResult.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegment.java scanned file 39.9 KB LogSegment.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegmentOffsetOverflowException.java scanned file 1.7 KB LogSegmentOffsetOverflowException.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java scanned file 10.4 KB LogSegments.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogStartOffsetIncrementReason.java scanned file 1.3 KB LogStartOffsetIncrementReason.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogToClean.java scanned file 4.6 KB LogToClean.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogTruncation.java scanned file 1.3 KB LogTruncation.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java scanned file 30.6 KB LogValidator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetIndex.java scanned file 9.8 KB OffsetIndex.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetMap.java scanned file 1.2 KB OffsetMap.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetPosition.java scanned file 1.2 KB OffsetPosition.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetResultHolder.java scanned file 4.2 KB OffsetResultHolder.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetsOutOfOrderException.java scanned file 1.1 KB OffsetsOutOfOrderException.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/PreCleanStats.java scanned file 1.7 KB PreCleanStats.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerAppendInfo.java scanned file 17.9 KB ProducerAppendInfo.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateEntry.java scanned file 7.0 KB ProducerStateEntry.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManagerConfig.java scanned file 1.7 KB ProducerStateManagerConfig.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java scanned file 31.4 KB ProducerStateManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/RecordValidationException.java scanned file 1.6 KB RecordValidationException.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java scanned file 30.5 KB RemoteIndexCache.java .java Java text/html apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteLogReadResult.java scanned file 980 bytes RemoteLogReadResult.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteStorageFetchInfo.java scanned file 1.2 KB RemoteStorageFetchInfo.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteStorageThreadPool.java scanned file 3.9 KB RemoteStorageThreadPool.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/RollParams.java scanned file 1.1 KB RollParams.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/SegmentDeletionReason.java scanned file 1009 bytes SegmentDeletionReason.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/SkimpyOffsetMap.java scanned file 7.2 KB SkimpyOffsetMap.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/SnapshotFile.java scanned file 2.5 KB SnapshotFile.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/StorageAction.java scanned file 1.1 KB StorageAction.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/ThreadShutdownException.java scanned file 991 bytes ThreadShutdownException.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/ThrottledReplicaListValidator.java scanned file 2.1 KB ThrottledReplicaListValidator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java scanned file 12.2 KB TimeIndex.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/TimestampOffset.java scanned file 1.4 KB TimestampOffset.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/TransactionIndex.java scanned file 10.2 KB TransactionIndex.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/TxnIndexSearchResult.java scanned file 1.2 KB TxnIndexSearchResult.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/TxnMetadata.java scanned file 1.9 KB TxnMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java scanned file 147.7 KB UnifiedLog.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/VerificationGuard.java scanned file 2.1 KB VerificationGuard.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/VerificationStateEntry.java scanned file 4.1 KB VerificationStateEntry.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/utils/Throttler.java scanned file 4.5 KB Throttler.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java scanned file 20.4 KB BrokerTopicMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicStats.java scanned file 13.8 KB BrokerTopicStats.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/resources/message/ProducerSnapshot.json scanned file 2.6 KB ProducerSnapshot.json .json text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/resources/message/RemoteLogSegmentMetadataRecord.json scanned file 4.0 KB RemoteLogSegmentMetadataRecord.json .json text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/resources/message/RemoteLogSegmentMetadataSnapshotRecord.json scanned file 2.9 KB RemoteLogSegmentMetadataSnapshotRecord.json .json text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/resources/message/RemoteLogSegmentMetadataUpdateRecord.json scanned file 2.7 KB RemoteLogSegmentMetadataUpdateRecord.json .json text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/resources/message/RemotePartitionDeleteMetadataRecord.json scanned file 2.2 KB RemotePartitionDeleteMetadataRecord.json .json text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/admin/RemoteTopicCrudTest.java scanned file 33.6 KB RemoteTopicCrudTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/LogAppendTimeTest.java scanned file 6.6 KB LogAppendTimeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/ClassLoaderAwareRemoteLogMetadataManagerTest.java scanned file 2.4 KB ClassLoaderAwareRemoteLogMetadataManagerTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTaskTest.java scanned file 23.9 KB ConsumerTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogLeaderEpochStateTest.java scanned file 10.6 KB RemoteLogLeaderEpochStateTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java scanned file 9.8 KB RemoteLogMetadataCacheTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataFormatterTest.java scanned file 3.9 KB RemoteLogMetadataFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataManagerTestUtils.java scanned file 5.3 KB RemoteLogMetadataManagerTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSerdeTest.java scanned file 5.7 KB RemoteLogMetadataSerdeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataTransformTest.java scanned file 4.7 KB RemoteLogMetadataTransformTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogSegmentLifecycleTest.java scanned file 20.7 KB RemoteLogSegmentLifecycleTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataSnapshotTransformTest.java scanned file 2.7 KB RemoteLogSegmentMetadataSnapshotTransformTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransformTest.java scanned file 2.7 KB RemoteLogSegmentMetadataTransformTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataUpdateTransformTest.java scanned file 2.7 KB RemoteLogSegmentMetadataUpdateTransformTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerConfigTest.java scanned file 10.8 KB TopicBasedRemoteLogMetadataManagerConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest.java scanned file 11.1 KB TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerRestartTest.java scanned file 6.7 KB TopicBasedRemoteLogMetadataManagerRestartTest.java .java Java text/x-java apache-2.0