【专题-MQ】Kafka如何保证一致性

一致性：若某条消息对consumer可见，那么即使Leader挂了，在新Leader上数据依然可见。

ISR (In-Sync Replicas)是Leader在Zookeeper中动态维护基本保持同步的Replica列表，该列表中保存的是与Leader副本保持消息同步的所有副本对应的Follower节点id。ISR冗余备份机制核心逻辑围绕HW值、LEO值展开。

• LEO（last end offset）日志末端偏移量，记录了该副本对象底层日志文件中下一条消息的位移值。
• HW（highwatermark），高水印值，任何一个副本对象的HW值一定不大于其LEO值，而小于或等于HW值的所有消息被认为是“已提交的”或“已备份的”。consumer只能消费已提交的消息，HW之后的数据对consumer不可见。

标签：副本,HW,Kafka,MQ,消息,一致性,LEO,consumer,Leader
来源： https://www.cnblogs.com/xfeiyun/p/15971291.html