|
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
|
|
|
|
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/TopicBasedRemoteLogMetadataManagerTest.java
|
scanned
|
file
|
21.3 KB
|
TopicBasedRemoteLogMetadataManagerTest.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/quota/RLMQuotaManagerTest.java
|
scanned
|
file
|
5.5 KB
|
RLMQuotaManagerTest.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/quota/RLMQuotaMetricsTest.java
|
scanned
|
file
|
2.8 KB
|
RLMQuotaMetricsTest.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/storage/ClassLoaderAwareRemoteStorageManagerTest.java
|
scanned
|
file
|
2.0 KB
|
ClassLoaderAwareRemoteStorageManagerTest.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/storage/LocalTieredStorageCondition.java
|
scanned
|
file
|
11.4 KB
|
LocalTieredStorageCondition.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/storage/LocalTieredStorageEvent.java
|
scanned
|
file
|
6.3 KB
|
LocalTieredStorageEvent.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/storage/LocalTieredStorageHistory.java
|
scanned
|
file
|
4.8 KB
|
LocalTieredStorageHistory.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/storage/LocalTieredStorage.java
|
scanned
|
file
|
26.1 KB
|
LocalTieredStorage.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/storage/LocalTieredStorageListener.java
|
scanned
|
file
|
3.0 KB
|
LocalTieredStorageListener.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/storage/LocalTieredStorageSnapshot.java
|
scanned
|
file
|
3.8 KB
|
LocalTieredStorageSnapshot.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/storage/LocalTieredStorageTest.java
|
scanned
|
file
|
29.7 KB
|
LocalTieredStorageTest.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/storage/LocalTieredStorageTraverser.java
|
scanned
|
file
|
1.7 KB
|
LocalTieredStorageTraverser.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/storage/RemoteLogManagerConfigTest.java
|
scanned
|
file
|
7.8 KB
|
RemoteLogManagerConfigTest.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/storage/RemoteLogManagerTest.java
|
scanned
|
file
|
218.0 KB
|
RemoteLogManagerTest.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/storage/RemoteLogMetadataManagerTest.java
|
scanned
|
file
|
8.9 KB
|
RemoteLogMetadataManagerTest.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/storage/RemoteLogOffsetReaderTest.java
|
scanned
|
file
|
8.8 KB
|
RemoteLogOffsetReaderTest.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/storage/RemoteLogReaderTest.java
|
scanned
|
file
|
7.0 KB
|
RemoteLogReaderTest.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/storage/RemoteLogSegmentFileset.java
|
scanned
|
file
|
12.4 KB
|
RemoteLogSegmentFileset.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/storage/RemoteTopicPartitionDirectory.java
|
scanned
|
file
|
6.9 KB
|
RemoteTopicPartitionDirectory.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/storage/RemoteTopicPartitionDirectoryTest.java
|
scanned
|
file
|
2.1 KB
|
RemoteTopicPartitionDirectoryTest.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/storage/Transferer.java
|
scanned
|
file
|
1.3 KB
|
Transferer.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/purgatory/DelayedRemoteFetchTest.java
|
scanned
|
file
|
21.6 KB
|
DelayedRemoteFetchTest.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/purgatory/DelayedRemoteListOffsetsTest.java
|
scanned
|
file
|
15.0 KB
|
DelayedRemoteListOffsetsTest.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/storage/internals/checkpoint/CleanShutdownFileHandlerTest.java
|
scanned
|
file
|
3.6 KB
|
CleanShutdownFileHandlerTest.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/storage/internals/checkpoint/LeaderEpochCheckpointFileWithFailureHandlerTest.java
|
scanned
|
file
|
2.8 KB
|
LeaderEpochCheckpointFileWithFailureHandlerTest.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/storage/internals/checkpoint/OffsetCheckpointFileWithFailureHandlerTest.java
|
scanned
|
file
|
6.6 KB
|
OffsetCheckpointFileWithFailureHandlerTest.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/storage/internals/checkpoint/PartitionMetadataFileTest.java
|
scanned
|
file
|
3.8 KB
|
PartitionMetadataFileTest.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/storage/internals/log/AbstractIndexTest.java
|
scanned
|
file
|
3.0 KB
|
AbstractIndexTest.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/storage/internals/log/BrokerCompressionTest.java
|
scanned
|
file
|
4.7 KB
|
BrokerCompressionTest.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/storage/internals/log/LocalLogTest.java
|
scanned
|
file
|
32.4 KB
|
LocalLogTest.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/storage/internals/log/LogConcurrencyTest.java
|
scanned
|
file
|
8.5 KB
|
LogConcurrencyTest.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/storage/internals/log/LogManagerTest.java
|
scanned
|
file
|
8.3 KB
|
LogManagerTest.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/storage/internals/log/LogOffsetMetadataTest.java
|
scanned
|
file
|
3.8 KB
|
LogOffsetMetadataTest.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/storage/internals/log/LogSegmentsTest.java
|
scanned
|
file
|
11.8 KB
|
LogSegmentsTest.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/storage/internals/log/LogSegmentTest.java
|
scanned
|
file
|
40.4 KB
|
LogSegmentTest.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/storage/internals/log/LogTestUtils.java
|
scanned
|
file
|
1.8 KB
|
LogTestUtils.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/storage/internals/log/LogValidatorTest.java
|
scanned
|
file
|
83.1 KB
|
LogValidatorTest.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/storage/internals/log/OffsetIndexTest.java
|
scanned
|
file
|
10.7 KB
|
OffsetIndexTest.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/storage/internals/log/OffsetMapTest.java
|
scanned
|
file
|
3.6 KB
|
OffsetMapTest.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/storage/internals/log/ProducerStateManagerTest.java
|
scanned
|
file
|
76.2 KB
|
ProducerStateManagerTest.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/storage/internals/log/RemoteIndexCacheTest.java
|
scanned
|
file
|
70.6 KB
|
RemoteIndexCacheTest.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/storage/internals/log/TimeIndexTest.java
|
scanned
|
file
|
7.2 KB
|
TimeIndexTest.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/storage/internals/log/TransactionIndexTest.java
|
scanned
|
file
|
8.4 KB
|
TransactionIndexTest.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/storage/internals/log/UnifiedLogTest.java
|
scanned
|
file
|
1.3 KB
|
UnifiedLogTest.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/storage/internals/log/VerificationGuardTest.java
|
scanned
|
file
|
2.4 KB
|
VerificationGuardTest.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/storage/internals/utils/ThrottlerTest.java
|
scanned
|
file
|
5.0 KB
|
ThrottlerTest.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/tiered/storage/actions/AlterLogDirAction.java
|
scanned
|
file
|
4.1 KB
|
AlterLogDirAction.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/tiered/storage/actions/BounceBrokerAction.java
|
scanned
|
file
|
1.4 KB
|
BounceBrokerAction.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/tiered/storage/actions/ConsumeAction.java
|
scanned
|
file
|
11.0 KB
|
ConsumeAction.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/tiered/storage/actions/CreatePartitionsAction.java
|
scanned
|
file
|
1.6 KB
|
CreatePartitionsAction.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/tiered/storage/actions/CreateTopicAction.java
|
scanned
|
file
|
2.0 KB
|
CreateTopicAction.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/tiered/storage/actions/DeleteRecordsAction.java
|
scanned
|
file
|
3.7 KB
|
DeleteRecordsAction.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/tiered/storage/actions/DeleteTopicAction.java
|
scanned
|
file
|
4.0 KB
|
DeleteTopicAction.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/tiered/storage/actions/EraseBrokerStorageAction.java
|
scanned
|
file
|
2.0 KB
|
EraseBrokerStorageAction.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/tiered/storage/actions/ExpectBrokerInISRAction.java
|
scanned
|
file
|
2.4 KB
|
ExpectBrokerInISRAction.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/tiered/storage/actions/ExpectEmptyRemoteStorageAction.java
|
scanned
|
file
|
2.4 KB
|
ExpectEmptyRemoteStorageAction.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/tiered/storage/actions/ExpectLeaderAction.java
|
scanned
|
file
|
5.0 KB
|
ExpectLeaderAction.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/tiered/storage/actions/ExpectLeaderEpochCheckpointAction.java
|
scanned
|
file
|
3.2 KB
|
ExpectLeaderEpochCheckpointAction.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/tiered/storage/actions/ExpectListOffsetsAction.java
|
scanned
|
file
|
2.8 KB
|
ExpectListOffsetsAction.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/tiered/storage/actions/ExpectTopicIdToMatchInRemoteStorageAction.java
|
scanned
|
file
|
2.5 KB
|
ExpectTopicIdToMatchInRemoteStorageAction.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/tiered/storage/actions/ExpectUserTopicMappedToMetadataPartitionsAction.java
|
scanned
|
file
|
3.5 KB
|
ExpectUserTopicMappedToMetadataPartitionsAction.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/tiered/storage/actions/ProduceAction.java
|
scanned
|
file
|
8.5 KB
|
ProduceAction.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/tiered/storage/actions/ReassignReplicaAction.java
|
scanned
|
file
|
3.2 KB
|
ReassignReplicaAction.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/tiered/storage/actions/ShrinkReplicaAction.java
|
scanned
|
file
|
3.7 KB
|
ShrinkReplicaAction.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/tiered/storage/actions/StartBrokerAction.java
|
scanned
|
file
|
1.4 KB
|
StartBrokerAction.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/tiered/storage/actions/StopBrokerAction.java
|
scanned
|
file
|
1.4 KB
|
StopBrokerAction.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/tiered/storage/actions/UpdateBrokerConfigAction.java
|
scanned
|
file
|
2.1 KB
|
UpdateBrokerConfigAction.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/tiered/storage/actions/UpdateTopicConfigAction.java
|
scanned
|
file
|
2.1 KB
|
UpdateTopicConfigAction.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/tiered/storage/integration/AlterLogDirTest.java
|
scanned
|
file
|
3.1 KB
|
AlterLogDirTest.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/tiered/storage/integration/BaseDeleteSegmentsTest.java
|
scanned
|
file
|
3.8 KB
|
BaseDeleteSegmentsTest.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/tiered/storage/integration/BaseReassignReplicaTest.java
|
scanned
|
file
|
4.5 KB
|
BaseReassignReplicaTest.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/tiered/storage/integration/DeleteSegmentsByRetentionSizeTest.java
|
scanned
|
file
|
1.1 KB
|
DeleteSegmentsByRetentionSizeTest.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/tiered/storage/integration/DeleteSegmentsByRetentionTimeTest.java
|
scanned
|
file
|
1.1 KB
|
DeleteSegmentsByRetentionTimeTest.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/tiered/storage/integration/DeleteSegmentsDueToLogStartOffsetBreachTest.java
|
scanned
|
file
|
5.0 KB
|
DeleteSegmentsDueToLogStartOffsetBreachTest.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/tiered/storage/integration/DeleteTopicTest.java
|
scanned
|
file
|
3.5 KB
|
DeleteTopicTest.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/tiered/storage/integration/DisableRemoteLogOnTopicTest.java
|
scanned
|
file
|
5.9 KB
|
DisableRemoteLogOnTopicTest.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/tiered/storage/integration/EnableRemoteLogOnTopicTest.java
|
scanned
|
file
|
4.4 KB
|
EnableRemoteLogOnTopicTest.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/tiered/storage/integration/FetchFromLeaderWithCorruptedCheckpointTest.java
|
scanned
|
file
|
4.0 KB
|
FetchFromLeaderWithCorruptedCheckpointTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|