0%

kafka

kafka

ACK机制

Kafka producer有三种ack机制 初始化producer时在config中进行配置

ACK 同步 延迟
0 producer不等待broker同步完成就发送下一条(批)信息 低的延迟最弱的持久性,当服务器发生故障时,就很可能发生数据丢失。例如leader已经死亡,producer不知情,还会继续发送消息broker接收不到数据就会数据丢失
1 producer要等待leader成功收到数据并得到确认,才发送下一条message 较好的持久性较低的延迟性:Partition的Leader死亡,follwer尚未复制,数据就会丢失
-1 producer得到follwer确认,才发送下一条数据 持久性最好,延时性最差

三种机制性能递减,可靠性递增