6,866 results
« Page 42 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/DynamicVoter.java scanned file 5.4 KB DynamicVoter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/DynamicVoters.java scanned file 3.8 KB DynamicVoters.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ElectionState.java scanned file 7.1 KB ElectionState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/Endpoints.java scanned file 11.1 KB Endpoints.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/EpochState.java scanned file 2.4 KB EpochState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/errors/BufferAllocationException.java scanned file 1.1 KB BufferAllocationException.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/errors/NotLeaderException.java scanned file 1.3 KB NotLeaderException.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/errors/RaftException.java scanned file 1.3 KB RaftException.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ExpirationService.java scanned file 1.4 KB ExpirationService.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ExternalKRaftMetrics.java scanned file 1.1 KB ExternalKRaftMetrics.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/FileQuorumStateStore.java scanned file 7.6 KB FileQuorumStateStore.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/FollowerState.java scanned file 9.6 KB FollowerState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandler.java scanned file 14.5 KB AddVoterHandler.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandlerState.java scanned file 2.9 KB AddVoterHandlerState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java scanned file 22.4 KB BatchAccumulator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java scanned file 12.0 KB BatchBuilder.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/BatchMemoryPool.java scanned file 4.7 KB BatchMemoryPool.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/BlockingMessageQueue.java scanned file 2.4 KB BlockingMessageQueue.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/CloseListener.java scanned file 953 bytes CloseListener.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/DefaultRequestSender.java scanned file 4.1 KB DefaultRequestSender.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/EpochElection.java scanned file 5.8 KB EpochElection.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/FuturePurgatory.java scanned file 4.1 KB FuturePurgatory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/IdentitySerde.java scanned file 1.7 KB IdentitySerde.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftMetrics.java scanned file 13.1 KB KafkaRaftMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java scanned file 12.5 KB KRaftControlRecordStateMachine.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/KRaftVersionUpgrade.java scanned file 2.1 KB KRaftVersionUpgrade.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/LogHistory.java scanned file 2.7 KB LogHistory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/MemoryBatchReader.java scanned file 2.9 KB MemoryBatchReader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java scanned file 3.7 KB RecordsBatchReader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java scanned file 13.7 KB RecordsIterator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RemoveVoterHandler.java scanned file 8.0 KB RemoveVoterHandler.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RemoveVoterHandlerState.java scanned file 1.6 KB RemoveVoterHandlerState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RequestSender.java scanned file 1.8 KB RequestSender.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RequestSendResult.java scanned file 1.3 KB RequestSendResult.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/StringSerde.java scanned file 1.7 KB StringSerde.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/ThresholdPurgatory.java scanned file 3.2 KB ThresholdPurgatory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/TreeMapLogHistory.java scanned file 2.7 KB TreeMapLogHistory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandler.java scanned file 12.1 KB UpdateVoterHandler.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/VoterSetHistory.java scanned file 5.3 KB VoterSetHistory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/resources/common/message/QuorumStateData.json scanned file 1.8 KB QuorumStateData.json .json text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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