Kafka是如何保证数据可靠性和一致性？( 二 ) _经验知识

一致性定义:若某条消息对Consumer可见,那么即使Leader宕机了,在新Leader上数据依然可以被读到
* HighWaterMark简称HW: Partition的高水位。取一个partition对应的ISR中最小的LEO作为HW 。消费者最多只能消费到HW所在的位置。另外每个replica都有highWatermark 。leader和follower各自负责更新自己的highWatermark状态。highWatermark <= leader. LogEndOffset
* 对于Leader新写入的msg 。Consumer不能立刻消费。Leader会等待该消息被所有ISR中的replica同步后,更新HW,此时该消息才能被Consumer消费。即Consumer最多只能消费到HW位置
这样就保证了如果Leader Broker失效,该消息仍然可以从新选举的Leader中获取。对于来自内部Broker的读取请求,没有HW的限制。同时,Follower也会维护一份自己的HW,Folloer.HW = min(Leader.HW, Follower.offset)

Kafka是如何保证数据可靠性和一致性？( 二 )

推荐阅读

中秋节有什么传统

MathType如何编辑行列式？MathType编辑行列式的操作步骤

来日方长什么意思内涵方长是谁

遇到无知且无畏的领导该怎么办？

刘邦为什么能够得天下

镁和乙醇会反应吗

埃及旅游一般多少钱埃及旅游

树叶的折法树叶怎么折

美的定频5P空调E8什么故障,是什么原因?

永恒战士安卓,【酷航酷航空》中文版下载地址是

喝了一个月沙棘汁减肥吗

怎样拍好人物风景照片

绝句是什么体裁的诗，绝句属于什么诗体

旗舰机|入手就不会后悔的4款手机，从千元机到旗舰机，每款都很能打

wifi拒绝接入是什么意思（wifi拒绝接入的意思是啥）

微信经常换个性签名的人是什么心理？

车标是文字的车车标是字的车

华为手机信号出现沙漏华为手机信号沙漏标志

两个月的小狗拉稀怎么办

鬼谷八荒炼狱山挥怎么过鬼谷八荒山挥打法心得分享