Kafka中的ISR、AR又代表什么?ISR的伸缩又指什么_kafka isr ar
ISR:In-Sync Replicas 副本同步队列
AR:Assigned Replicas 所有副本ISR是由leader维护,follower从leader同步数据有⼀些延迟(包括延迟时间replica.lag.time.max.ms和延迟条数replica.lag.max.messages两个维度, 当前最新的版本0.10.x中只⽀持replica.lag.time.max.ms这个维度),任意⼀个超过阈值都会把follower剔除出ISR, 存⼊OSR(Outof-Sync Replicas)列表,新加⼊的follower也会先存放在OSR中。AR=ISR+OSR。
📚 Kafka的ISR与AR机制深度解析
从副本同步原理到ISR动态伸缩,结合Kafka源码和运维实践,全面剖析这一保障高可用的核心设计。
1. 📌 核心概念定义
2. 🏗️ ISR工作机制图解
3. ⚙️ ISR动态伸缩机制
▎ 进入ISR的条件
-
Follower完成最新HW(High Watermark)追赶
-
持续同步时间超过
replica.lag.time.max.ms
(默认30秒)