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

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