KAFKA-10527; Voters should not reinitialize as leader in same epoch (#9348)
One of the invariants that the raft replication protocol relies on is that each record is uniquely identified by leader epoch and offset. This can be violated if a leader remains elected with the same epoch between restarts since unflushed data could be lost. Reviewers: Guozhang Wang <wangguoz@gmail.com>
显示
- raft/src/main/java/org/apache/kafka/raft/QuorumState.java 8 个添加, 4 个删除raft/src/main/java/org/apache/kafka/raft/QuorumState.java
- raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java 74 个添加, 24 个删除.../test/java/org/apache/kafka/raft/KafkaRaftClientTest.java
- raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java 13 个添加, 4 个删除.../src/test/java/org/apache/kafka/raft/QuorumStateTest.java
- raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java 23 个添加, 87 个删除...t/java/org/apache/kafka/raft/RaftEventSimulationTest.java
加载中
想要评论请 注册 或 登录