Kafka检测URP方法及副本同步延迟相关技术问题咨询

1. Kafka 如何检测 URP（Under Replicated Partitions，同步滞后分区） #

Kafka 对 URP 的检测是由集群 Controller 节点和分区 Leader 副本配合完成的，具体逻辑如下：

• 每个分区的 Leader 副本会实时维护所有跟随者副本的两个核心状态：最后一次同步的消息偏移量（LEO）、最后一次成功追上 Leader 最新偏移量的时间戳
• 集群默认配置了replica.lag.time.max.ms参数（默认30秒），如果某跟随者副本连续超过该时长没有向 Leader 发起同步请求，或者同步的偏移量一直跟不上 Leader 的最新写入进度，Leader 就会将该副本标记为「不同步」状态
• Controller 节点会定期向所有 Broker 拉取元数据更新，拿到分区的副本同步状态后，就会将存在不同步副本的分区计入 URP 列表
• 你也可以通过 Kafka 自带的命令行工具主动查询当前集群的 URP 情况：
  kafka-topics.sh --describe --under-replicated-partitions --bootstrap-server <broker接入地址>

2. 若 Kafka 消费者侧持续有数据拉取，副本是否一定会出现同步延迟？ #

答案是不一定，首先需要明确：消费者拉取数据的流程和副本同步的流程是互相独立的，消费者流量本身不会直接触发副本同步延迟。
只要满足以下条件，就算消费者持续有较高的流量，副本也可以保持正常同步：

• Broker 节点的 CPU、磁盘IO、网络带宽等硬件资源没有出现瓶颈，副本同步请求的优先级不会被消费者请求挤占
• 生产者的写入速度没有长期超过跟随者副本的同步能力上限
• 集群没有出现网络分区、Broker 进程卡顿、磁盘故障这类异常情况

只有当出现资源瓶颈、配置不合理、集群故障等场景时，才会出现副本同步延迟的问题。

内容的提问来源于stack exchange，提问作者Shreya Singhal