> 技术文档 > Kafka中的ISR、AR又代表什么?ISR的伸缩又指什么_kafka isr ar

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. 📌 核心概念定义
术语 全称 含义 组成关系 AR Assigned Replicas 分区所有副本(包括Leader和Follower) AR = ISR + OSR ISR In-Sync Replicas 与Leader数据同步的副本集合(含Leader自身) ISR ⊆ AR OSR Out-of-Sync Replicas 同步滞后超过阈值的副本 OSR = AR - ISR
2. 🏗️ ISR工作机制图解

3. ⚙️ ISR动态伸缩机制

▎ 进入ISR的条件

  1. Follower完成最新HW(High Watermark)追赶

  2. 持续同步时间超过replica.lag.time.max.ms(默认30秒)

    
    

上海别克