Kafka 3.0新特性全面曝光,真香!
盖。leader为了最大程度的保证日志的一致性,且保证日志最大量,leader会寻找follower与他日志一致的地方,然后覆盖follower之后的所有日志条目,从而实现日志数据的一致性。具体的操作就是:leader会从后往前不断对比,每次Append Entries失败后尝试前一个日志条目,直到成功找到每个Follower的日志一致的位置点,然后向该Follower所在位置之后的条目进行覆盖。详细过程如下:Leader维护了每个Follower节点下一次要接收的日志的索引,即nextIndex。Leader选举成功后将所有Follower的nextIndex设置为自己的最后一个日志条目+1。Leader将数据推送给Follower,如果Follower验证失败(nextIndex不匹配...阅读全文