Kafka的ACK（Acknowledgment）机制是用于确保消息可靠传递的关键组件之一。生产者在发送消息到Kafka集群时，可以通过设置不同的acks参数值来控制消息发送后的确认机制，从而平衡消息的可靠性和延迟时间。
- acks=0：此模式下，生产者在发送消息后不会等待任何来自Broker的确认响应。这意味着一旦消息被发送出去，即使Broker没有成功写入磁盘，生产者也会继续处理其他任务。这种模式适用于对延迟要求极高且可以容忍一定数据丢失的场景，但如果Broker发生故障，可能会导致消息丢失。
- acks=1：在此模式下，生产者需要等待Leader副本成功将消息写入本地日志文件后才返回确认。这种模式提供了一定的可靠性保证，因为至少有一个副本已经保存了消息。如果Leader副本在follower副本同步之前崩溃，消息可能会丢失。这种模式适用于大多数应用场景，能够在可接受的延迟范围内提供较好的消息可靠性。
- acks=all或acks=-1：在此模式下，生产者需要等待所有在ISR（In-Sync Replicas）中的副本都成功写入消息后才返回确认。这种模式提供了最高的消息可靠性保证，因为只有当所有副本都成功写入消息时，生产者才认为消息已经成功发送。这种模式适用于对消息可靠性要求极高的场景，但相应的延迟也会增加。这确保了消息的可靠性，但会导致更长的延迟。
Kafka的ACK机制通过提供不同级别的确认策略，使得生产者可以根据具体的业务需求和对消息可靠性的要求，在吞吐量和消息可靠性之间做出权衡.
本文转载自: https://blog.csdn.net/wu6cfp38/article/details/139112842
版权归原作者 6个日的梦想 所有， 如有侵权，请联系我们删除。
版权归原作者 6个日的梦想 所有， 如有侵权，请联系我们删除。