Path	Lines of Code
raft/config/kraft-log4j2.yaml	21
raft/src/main/java/org/apache/kafka/raft/Batch.java	144
raft/src/main/java/org/apache/kafka/raft/BatchReader.java	9
raft/src/main/java/org/apache/kafka/raft/CandidateState.java	166
raft/src/main/java/org/apache/kafka/raft/ControlRecord.java	77
raft/src/main/java/org/apache/kafka/raft/DynamicVoter.java	137
raft/src/main/java/org/apache/kafka/raft/DynamicVoters.java	66
raft/src/main/java/org/apache/kafka/raft/ElectionState.java	152
raft/src/main/java/org/apache/kafka/raft/Endpoints.java	250
raft/src/main/java/org/apache/kafka/raft/EpochState.java	13
raft/src/main/java/org/apache/kafka/raft/ExpirationService.java	5
raft/src/main/java/org/apache/kafka/raft/ExternalKRaftMetrics.java	4
raft/src/main/java/org/apache/kafka/raft/FileQuorumStateStore.java	143
raft/src/main/java/org/apache/kafka/raft/FollowerState.java	220
raft/src/main/java/org/apache/kafka/raft/Isolation.java	5
raft/src/main/java/org/apache/kafka/raft/KafkaNetworkChannel.java	155
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java	3122
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClientDriver.java	79
raft/src/main/java/org/apache/kafka/raft/LeaderAndEpoch.java	40
raft/src/main/java/org/apache/kafka/raft/LeaderState.java	874
raft/src/main/java/org/apache/kafka/raft/LogAppendInfo.java	2
raft/src/main/java/org/apache/kafka/raft/LogFetchInfo.java	10
raft/src/main/java/org/apache/kafka/raft/LogOffsetMetadata.java	38
raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java	123
raft/src/main/java/org/apache/kafka/raft/NetworkChannel.java	8
raft/src/main/java/org/apache/kafka/raft/NomineeState.java	9
raft/src/main/java/org/apache/kafka/raft/OffsetMetadata.java	3
raft/src/main/java/org/apache/kafka/raft/ProspectiveState.java	135
raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java	233
raft/src/main/java/org/apache/kafka/raft/QuorumState.java	719
raft/src/main/java/org/apache/kafka/raft/QuorumStateStore.java	10
raft/src/main/java/org/apache/kafka/raft/RaftClient.java	38
raft/src/main/java/org/apache/kafka/raft/RaftMessage.java	6
raft/src/main/java/org/apache/kafka/raft/RaftMessageQueue.java	7
raft/src/main/java/org/apache/kafka/raft/RaftRequest.java	81
raft/src/main/java/org/apache/kafka/raft/RaftResponse.java	51
raft/src/main/java/org/apache/kafka/raft/RaftUtil.java	653
raft/src/main/java/org/apache/kafka/raft/ReplicaKey.java	52
raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java	77
raft/src/main/java/org/apache/kafka/raft/RequestManager.java	241
raft/src/main/java/org/apache/kafka/raft/ResignedState.java	106
raft/src/main/java/org/apache/kafka/raft/SegmentPosition.java	7
raft/src/main/java/org/apache/kafka/raft/TimingWheelExpirationService.java	49
raft/src/main/java/org/apache/kafka/raft/UnattachedState.java	105
raft/src/main/java/org/apache/kafka/raft/ValidOffsetAndEpoch.java	52
raft/src/main/java/org/apache/kafka/raft/VoterSet.java	281
raft/src/main/java/org/apache/kafka/raft/errors/BufferAllocationException.java	7
raft/src/main/java/org/apache/kafka/raft/errors/NotLeaderException.java	13
raft/src/main/java/org/apache/kafka/raft/errors/RaftException.java	14
raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandler.java	268
raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandlerState.java	56
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java	451
raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java	221
raft/src/main/java/org/apache/kafka/raft/internals/BatchMemoryPool.java	80
raft/src/main/java/org/apache/kafka/raft/internals/BlockingMessageQueue.java	50
raft/src/main/java/org/apache/kafka/raft/internals/CloseListener.java	5
raft/src/main/java/org/apache/kafka/raft/internals/DefaultRequestSender.java	79
raft/src/main/java/org/apache/kafka/raft/internals/EpochElection.java	110
raft/src/main/java/org/apache/kafka/raft/internals/FuturePurgatory.java	9
raft/src/main/java/org/apache/kafka/raft/internals/IdentitySerde.java	21
raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java	220
raft/src/main/java/org/apache/kafka/raft/internals/KRaftVersionUpgrade.java	30
raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftMetrics.java	223
raft/src/main/java/org/apache/kafka/raft/internals/LogHistory.java	11
raft/src/main/java/org/apache/kafka/raft/internals/MemoryBatchReader.java	71
raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java	93
raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java	292
raft/src/main/java/org/apache/kafka/raft/internals/RemoveVoterHandler.java	133
raft/src/main/java/org/apache/kafka/raft/internals/RemoveVoterHandlerState.java	23
raft/src/main/java/org/apache/kafka/raft/internals/RequestSendResult.java	6
raft/src/main/java/org/apache/kafka/raft/internals/RequestSender.java	14
raft/src/main/java/org/apache/kafka/raft/internals/StringSerde.java	24
raft/src/main/java/org/apache/kafka/raft/internals/ThresholdPurgatory.java	65
raft/src/main/java/org/apache/kafka/raft/internals/TimeRatio.java	43
raft/src/main/java/org/apache/kafka/raft/internals/TreeMapLogHistory.java	46
raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandler.java	242
raft/src/main/java/org/apache/kafka/raft/internals/VoterSetHistory.java	54
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java	61
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java	151
raft/src/main/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriter.java	46
raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java	10
raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotWriter.java	13
raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java	114
raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java	207
raft/src/main/java/org/apache/kafka/snapshot/SnapshotPath.java	4
raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java	11
raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java	13
raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java	134