Kafka中的 ISR 机制-Toy模板网

这篇具有很好参考价值的文章主要介绍了Kafka中的 ISR 机制。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

ISR 是什么

ISR 的全称叫做： In-Sync Replicas （同步副本集）, 可以理解为和 leader 保持同步的所有副本的集合。ISR 动态维护了一个和 leader 副本保持同步副本集合，ISR 中的副本全部都和 leader 的数据保持同步。

设一个场景，有6个分区集合，分别为 [0,1,2,3,4,5]，其中 leader-replica 是 0

其中 [1,2,3] 作为 follower 和 leader 的数据保持同步，而 [4,5] 未能和 leader 保持同步，那么此时，ISR=[0,1,2,3]，OSR=[4,5]

如果此时副本 4 追上了 leader-replica，也就是和 leader 保持到了同步，那么此时，ISR=[0,1,2,3,4]，OSR=[5]

我们知道了与 leader 保持同步的副本集后，可以做到哪些事情？

通过 ISR 就可以知晓了哪些 follower 与 leader 保持着同步，在写入消息的时候，设置写入处于 ISR 中所有的副本才算成功，在进行 leader 切换的时候，就可以从 ISR 中选择对应的 follower 成为新的 leader。

ISR 的作用是通过副本机制实现消息高可靠，服务高可用时，不可缺少的一环；这也是为什么讲到副本不得不提到 ISR 的原因。

总结

在一些中间件中，都有副本的概念，不同场景下写入数据时，要求写入副本的个数也不尽相同。例如 zk 中要求写入的节点个数大于一半才算成功，或者有些要求高可靠性的场景，规定写入所有副本才能算成功。

而 kafka 的 ISR 可以允许生产消息时，根据自己的业务场景自行配置 ACK 确认机制达到想要的效果：

ISR 虽然是动态伸缩的，可能会出现 follower 全部都挂了的情况，如果 ISR 中只剩下 leader，那么此时设置 acks=all 就等价于 acks=1 了。这样就会对高可靠性要求的场景产生危险。

kafka 提供了 min.insync.replicas 参数配置，这个参数可以配置最少 ISR 中需要多少个副本，才能继续提供写服务。如果设置为 2，一旦 ISR 中的个数小于 2，那么就不再提供写服务，牺牲一定的可用性，来保障这种高可靠的场景需求。

ISR 机制的存在是 kafka 为了平衡可靠性和可用性，不指定提供高可靠或者高可用的服务，而是将决定权交给了使用者，让使用者通过参数来控制，到底要实现什么程度的高可靠与高可用。文章来源地址https://www.toymoban.com/news/detail-673035.html

到了这里，关于Kafka中的 ISR 机制的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！