Kafka MirrorMaker2 跨区域复制与一致性治理（2025）

# Kafka MirrorMaker2 跨区域复制与一致性治理（2025） ## 一、拓扑与链路 - 拓扑：源集群→（MirrorMaker2）→ 目标集群，多区域互备；避免环路。 - 连接器：配置 `replication.policy.class` 与心跳/检查点主题，确保位点同步。 ## 二、延迟与吞吐 - 延迟（延迟）：监控复制延迟与网络 RTT；按批大小与并发调节。 - 吞吐：压缩与批量写优化；限速避免拥塞。 ## 三、一致性与过滤 - 一致性（一致性）：确保关键主题有序复制；对幂等生产与事务主题配置特殊策略。 - 过滤（过滤）：按命名空间/前缀/标签过滤复制范围，降低成本。 ## 四、循环与冲突 - 循环避免：设置集群标识与 topic 重命名规则，防止回环复制。 - 冲突：跨区域写入时采用主从策略或冲突解决流程。 ## 五、观测与回滚 - 指标：复制延迟、失败率、滞留消息、检查点滞后。 - 回滚：链路异常时暂停复制并回退到最新一致位点。 ## 注意事项 - 关键词（MirrorMaker2、复制、延迟、一致性、过滤）与正文一致。 - 分类为“数据/消息/Kafka”，不超过三级。 - 参数需在跨区域演练与容量评估下验证。