Kafka复制中的消息确认机制

Kafka 使用一种称为 “acks” 的配置选项来确定在将消息标记为已提交之前需要多少个副本收到消息

1. acks=0：生产者将消息发送给分区的 leader，不等待任何确认。这意味着如果 leader 崩溃，消息可能会丢失。这是性能最高的设置，但也是最不安全的。
2. acks=1（默认值）：生产者将消息发送给分区的 leader，并等待 leader 确认接收。这意味着如果 leader 崩溃，其他 follower 可以成为新的 leader，并且消息不会丢失。这比 acks=0 更安全，但性能稍差。
3. acks=all（或 acks=-1）：生产者将消息发送给分区的 leader，并等待 leader 和所有同步的 follower 确认接收。这意味着只有当所有副本都收到消息时，消息才被视为已提交。这是最安全的设置，但性能较差。

此外，还有一个名为 min.insync.replicas 的配置选项，它定义了必须保持同步的最小副本数。如果同步副本数低于此值，Kafka 将拒绝生产者的写入请求。这有助于确保在发生故障时，仍然有足够的副本来保证消息的持久性。

总之，Kafka 通过 acks 配置选项和消息确认机制来确保消息的持久性和可靠性。生产者可以根据需要选择不同的确认级别，以在性能和安全性之间取得平衡。