Kafka消息ACK机制
2021-04-27 20:18:09 0 举报
Kafka消息ACK机制
作者其他创作
大纲/内容
2
Follower1
5
5、其中一个Follower完全catch-up，另一个只取了一部分。由于所有的ISR都复制了消息4，Leader的HW移动到4，但Follower2还没有复制消息5，所以HW不会更新到5
1
3
LEO
HW|LEO
HW
Follower2
6、所有的ISR都复制了消息5，Leader的HW移动到LEO最大值
Leader
4
1、Follower完全赶上Leader，如果Leader无消息，则阻塞
2、Producer
4、Leader有新消息，将阻塞的Follower解锁并通知他们来取消息，Follower开始获取消息
3、Producer写入消息，Leader更新LEO
0 条评论
回复 删除
下一页
