kafka的三种ACK机制
2025-02-23 13:27:00 0 举报kafka的三种ACK机制
作者其他创作
大纲/内容
NetworkClient
ACKS = -1(all)
副本同步完成
Broker（Leader）
Leader已将数据保存到文本
ReplicaManager
应答处理的第一个级别：ACKS = 0效率最高，但是不安全，因为不确定leader和follower是否已将数据保存到文本
SockerServer
Sender
Main
Broker（Follower）
数据同步
Producer
应答处理的第三个级别：ACKS = -1(all)，默认值效率最低，但是最安全，需要同时确保leader和follower(所有ISR)均已将数据保存到文本
Buffer
ACKS = 0
ISR
ACKS = 1
应答处理的第二个级别：ACKS = 1效率和安全居中，只需要leader已将数据保存到文本即可，但是如果leader挂了，但是follower还没有同步，此时会造成数据丢失
收藏
0 条评论
下一页
