Kafka中的ACK机制

Kafka中的ACK机制

 

Kafka集群的节点为Broker,Broker中存取数据的基本单位为partition,leader(红色)和多个replica(蓝色)分别为指定Topic下的消息载体,生产者根据消息的topic和key值,确定了消息要发往哪个partition之后,会找到partition对应的leader,然后将消息发给leader,leader负责消息的写入,并与其余的replica进行同步。

ACK = 0 时 发送一次 不论leader是否接收

ACK = 1 时,等待leader接收成功即可

ACK = -1 时 ,需等待leader将消息同步给follower