kafka的ack配置
时间: 2023-11-19 11:56:37 浏览: 122
Kafka3.0详解,客户端命令,核心配置文件详解。spring集成、webflux集成、集群搭建
Kafka的ack配置是指在生产者发送消息到Kafka集群后,集群返回ack确认消息已经被成功接收的机制。Kafka提供了三种可靠性级别,用户可以根据对可靠性和延迟的要求进行权衡,选择以下的配置:
1. acks=0:producer不等待broker的ack,这一操作提供了一个最低的延迟,broker一接收到还没有写入磁盘就已经返回,当broker故障时有可能丢失数据;
2. acks=1(默认):producer等待broker的ack,partition的leader落盘成功后返回ack,如果在follower同步成功之前leader故障,那么将会丢失数据;
3. acks=-1/all:producer等待broker的ack,partition的leader和follower(ISR里的follower,不是全部的follower)全部落盘成功后才返回ack。但是如果在follower同步完成后,broker发送ack之前,leader发生故障,那么会造成数据重复。
相关问题:
阅读全文