5,643 results
« Page 33 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/Isolation.java scanned file 888 bytes Isolation.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/KafkaNetworkChannel.java scanned file 8.8 KB KafkaNetworkChannel.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/KafkaRaftClientDriver.java scanned file 4.1 KB KafkaRaftClientDriver.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java scanned file 168.8 KB KafkaRaftClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/LeaderAndEpoch.java scanned file 1.2 KB LeaderAndEpoch.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/LeaderState.java scanned file 46.1 KB LeaderState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/LogAppendInfo.java scanned file 955 bytes LogAppendInfo.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/LogFetchInfo.java scanned file 1.3 KB LogFetchInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/LogOffsetMetadata.java scanned file 1.9 KB LogOffsetMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java scanned file 10.3 KB MetadataLogConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/NetworkChannel.java scanned file 1.6 KB NetworkChannel.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/NomineeState.java scanned file 1.9 KB NomineeState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/OffsetMetadata.java scanned file 946 bytes OffsetMetadata.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ProspectiveState.java scanned file 5.5 KB ProspectiveState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java scanned file 14.9 KB QuorumConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/QuorumState.java scanned file 35.0 KB QuorumState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/QuorumStateStore.java scanned file 1.8 KB QuorumStateStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftClient.java scanned file 11.8 KB RaftClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftManager.java scanned file 1.7 KB RaftManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftMessage.java scanned file 966 bytes RaftMessage.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftMessageQueue.java scanned file 2.0 KB RaftMessageQueue.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftRequest.java scanned file 3.5 KB RaftRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftResponse.java scanned file 2.3 KB RaftResponse.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftUtil.java scanned file 32.2 KB RaftUtil.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ReplicaKey.java scanned file 2.5 KB ReplicaKey.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java scanned file 12.6 KB ReplicatedLog.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RequestManager.java scanned file 13.2 KB RequestManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ResignedState.java scanned file 5.8 KB ResignedState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/SegmentPosition.java scanned file 1.1 KB SegmentPosition.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/TimingWheelExpirationService.java scanned file 2.7 KB TimingWheelExpirationService.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/UnattachedState.java scanned file 4.8 KB UnattachedState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ValidOffsetAndEpoch.java scanned file 2.5 KB ValidOffsetAndEpoch.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/VoterSet.java scanned file 17.8 KB VoterSet.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java scanned file 3.1 KB FileRawSnapshotReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java scanned file 6.3 KB FileRawSnapshotWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriter.java scanned file 2.5 KB NotifyingRawSnapshotWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java scanned file 1.8 KB RawSnapshotReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotWriter.java scanned file 2.5 KB RawSnapshotWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java scanned file 5.2 KB RecordsSnapshotReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java scanned file 9.2 KB RecordsSnapshotWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/SnapshotPath.java scanned file 1021 bytes SnapshotPath.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java scanned file 2.3 KB SnapshotReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java scanned file 7.1 KB Snapshots.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java scanned file 2.9 KB SnapshotWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/CandidateStateTest.java scanned file 12.1 KB CandidateStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ControlRecordTest.java scanned file 2.3 KB ControlRecordTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/DynamicVotersTest.java scanned file 4.3 KB DynamicVotersTest.java .java Java text/x-Algol68 apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/DynamicVoterTest.java scanned file 7.1 KB DynamicVoterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ElectionStateTest.java scanned file 4.3 KB ElectionStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/EndpointsTest.java scanned file 15.1 KB EndpointsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/EpochElectionTest.java scanned file 6.1 KB EpochElectionTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/FileQuorumStateStoreTest.java scanned file 8.7 KB FileQuorumStateStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/FollowerStateTest.java scanned file 6.6 KB FollowerStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/BatchAccumulatorTest.java scanned file 26.0 KB BatchAccumulatorTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/BatchBuilderTest.java scanned file 4.6 KB BatchBuilderTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/BatchMemoryPoolTest.java scanned file 5.1 KB BatchMemoryPoolTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/BlockingMessageQueueTest.java scanned file 2.1 KB BlockingMessageQueueTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/KafkaRaftMetricsTest.java scanned file 23.4 KB KafkaRaftMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachineTest.java scanned file 19.5 KB KRaftControlRecordStateMachineTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/MemoryBatchReaderTest.java scanned file 2.3 KB MemoryBatchReaderTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/RecordsBatchReaderTest.java scanned file 5.7 KB RecordsBatchReaderTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/RecordsIteratorTest.java scanned file 19.4 KB RecordsIteratorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/ThresholdPurgatoryTest.java scanned file 6.4 KB ThresholdPurgatoryTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/TreeMapLogHistoryTest.java scanned file 4.5 KB TreeMapLogHistoryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/VoterSetHistoryTest.java scanned file 11.2 KB VoterSetHistoryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaNetworkChannelTest.java scanned file 17.7 KB KafkaNetworkChannelTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientAutoJoinTest.java scanned file 12.7 KB KafkaRaftClientAutoJoinTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientClusterAuthTest.java scanned file 6.3 KB KafkaRaftClientClusterAuthTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientDriverTest.java scanned file 3.5 KB KafkaRaftClientDriverTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientFetchTest.java scanned file 17.8 KB KafkaRaftClientFetchTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientPreVoteTest.java scanned file 50.8 KB KafkaRaftClientPreVoteTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java scanned file 118.7 KB KafkaRaftClientReconfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java scanned file 92.6 KB KafkaRaftClientSnapshotTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java scanned file 203.5 KB KafkaRaftClientTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/LeaderAndEpochTest.java scanned file 1.8 KB LeaderAndEpochTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/LeaderStateTest.java scanned file 37.6 KB LeaderStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockableRandom.java scanned file 1.7 KB MockableRandom.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockExpirationService.java scanned file 2.8 KB MockExpirationService.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockExpirationServiceTest.java scanned file 2.1 KB MockExpirationServiceTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockLog.java scanned file 24.3 KB MockLog.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockLogTest.java scanned file 40.1 KB MockLogTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockMessageQueue.java scanned file 2.1 KB MockMessageQueue.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockNetworkChannel.java scanned file 3.1 KB MockNetworkChannel.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockQuorumStateStore.java scanned file 1.7 KB MockQuorumStateStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ProspectiveStateTest.java scanned file 19.8 KB ProspectiveStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/QuorumConfigTest.java scanned file 2.6 KB QuorumConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java scanned file 109.2 KB QuorumStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java scanned file 89.7 KB RaftClientTestContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java scanned file 57.3 KB RaftEventSimulationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RaftUtilTest.java scanned file 38.4 KB RaftUtilTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ReplicatedCounter.java scanned file 7.7 KB ReplicatedCounter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java scanned file 11.7 KB RequestManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ResignedStateTest.java scanned file 4.9 KB ResignedStateTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/UnattachedStateTest.java scanned file 8.8 KB UnattachedStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ValidOffsetAndEpochTest.java scanned file 2.0 KB ValidOffsetAndEpochTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/VoterSetTest.java scanned file 16.8 KB VoterSetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/FileRawSnapshotTest.java scanned file 13.5 KB FileRawSnapshotTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/MockRawSnapshotReader.java scanned file 2.1 KB MockRawSnapshotReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/MockRawSnapshotWriter.java scanned file 3.0 KB MockRawSnapshotWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriterTest.java scanned file 3.8 KB NotifyingRawSnapshotWriterTest.java .java Java text/x-java apache-2.0