Kafka 使用一种称为 “acks” 的配置选项来确定在将消息标记为已提交之前需要多少个副本收到消息
此外，还有一个名为 min.insync.replicas 的配置选项，它定义了必须保持同步的最小副本数。如果同步副本数低于此值，Kafka 将拒绝生产者的写入请求。这有助于确保在发生故障时，仍然有足够的副本来保证消息的持久性。
总之，Kafka 通过 acks 配置选项和消息确认机制来确保消息的持久性和可靠性。生产者可以根据需要选择不同的确认级别，以在性能和安全性之间取得平衡。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
