Bulk Operation

KAFKA-9876 KRaft Obsever are not required to flush on every append

KAFKA-9876 Resign leader on network partition

KAFKA-9876 Notify listener of leader change on registration

KAFKA-9876 Validate node id, process role and quorum voters

KAFKA-9876 Revisit the usage of BufferSuppliers in Kraft

KAFKA-9876 Remove the method RaftClient.leaderAndEpoch

KAFKA-9876 Make kraft configuration properties public

KAFKA-9876 Notify listeners of raft client shutdowns

KAFKA-9876 Add integration tests for "test-kraft-server-start"

KAFKA-9876 Use UncheckedIOException when wrapping IOException

KAFKA-9876 Support api to resign raft leadership

KAFKA-9876 Allow votes to be granted in resigned state

KAFKA-9876 Decide whether inconsistent cluster id error are fatal

KAFKA-9876 Extend LogManager to cover the metadata topic

KAFKA-9876 Raft should prevent truncation below high watermark

KAFKA-9876 Improve raft simulation tests

KAFKA-9876 ClusterId validation for Vote, BeginQourum and EndQuorum

KAFKA-9876 Improve KafkaRaftClient handling of graceful shutdown

KAFKA-9876 KafkaMetadataLog and MockLock should validate that appended epochs are monotonically

KAFKA-9876 KafkaRaftClient should use the LEO when appending LeaderChangeMessage

KAFKA-9876 Change the BatchAccumulator to split records into batches

KAFKA-9876 Support non-routable quorum voter addresses

KAFKA-9876 Loosen monotonic fetch offset validation by raft leader

KAFKA-9876 Raft observers should not require an id to fetch

KAFKA-9876 Consider better return type of RaftClient.scheduleAppend

KAFKA-9876 Refactor raft outbound request channel

KAFKA-9876 Consider using "acknowledged" over "endorsing" for voters which have recognized the current leader

KAFKA-9876 Ensure raft io thread wakes up after linger expiration

KAFKA-9876 Add clusterId validation to Fetch handling

KAFKA-9876 Add missing unit test for `UnattachedState`

KAFKA-9876 Complete fetches in purgatory immediately after raft leader resigns

KAFKA-9876 Decide whether Raft listener callback errors are fatal

KAFKA-9876 Add resigned state to raft state machine to preserve leader/epoch information

KAFKA-9876 Raft leader should resign after write failures

KAFKA-9876 Raft leader should flush accumulated writes after a min size is reached

KAFKA-9876 Fix VotedToUnattached test error

KAFKA-9876 Bypass log validation for writes to raft log

KAFKA-9876 LeaderChangeMessage should include the leader as one of the voters

KAFKA-9876 Raft client should push all committed data to listeners

KAFKA-9876 Add linger semantics to raft

KAFKA-9876 Enhance Raft exception handling

KAFKA-9876 Add log flush semantics to simulation test

KAFKA-9876 Voters should always initialize as followers

KAFKA-9876 Explore performance impact of leader fsync deferral

KAFKA-9876 Unit tests for VotedState

KAFKA-9876 Fix minor behavior difference in `MockLog`

KAFKA-9876 Core Raft implementation

KAFKA-9876 Fix edge case in Raft truncation protocol

KAFKA-9876 Fetch protocol changes for KIP-595