Kafka的ACK(Acknowledgment)机制是指生产者发送消息后,需要等待多少个副本成功写入消息,生产者才会认为消息写入成功。这个机制是通过生产者的acks
参数进行配置的。acks
参数有三个可能的值:
这个ACK机制提供了一种权衡,允许生产者在可靠性和延迟之间进行选择。在使用时,可以根据应用程序的要求和对消息传递的可靠性需求进行配置。
在Kafka中,还有一个与acks
参数相关的参数是min.insync.replicas
,用于指定一个分区中至少要保持的ISR中的最小副本数量。如果ISR中的副本数量低于这个值,就会导致生产者不再能够发送消息。这进一步增加了消息的可靠性。
Proudly powered by WordPress