---

title: Kafka MirrorMaker 2多集群复制治理

keywords:

• MirrorMaker2
• replication.policy.class
• checkpoints
• heartbeats
• failover

description: 基于 MM2 的 Connect 框架进行跨集群主题与偏移复制，治理命名、心跳与故障切换策略。

tags:

• Kafka
• MirrorMaker2
• checkpoints
• failover
• heartbeats
• replication.policy.class
• 复制
• 数据

categories:

• 文章资讯
• 技术教程

---

Kafka MirrorMaker 2多集群复制治理

概览

• MM2 使用 Kafka Connect 在源与目标集群之间复制主题数据与消费偏移，支持双向拓扑与故障切换。
• 通过复制策略类控制主题命名与前缀；心跳与检查点主题用于健康与偏移同步。
• 在切换期间治理生产/消费流向与一致性。

技术参数（已验证）

• 拓扑：配置 clusters、源/目标连接器；支持双向与单向复制；心跳与检查点主题自动创建。
• 命名：replication.policy.class 控制前缀与名称规则；默认 DefaultReplicationPolicy。
• 偏移：自动同步消费组偏移到目标集群；在切换后进行偏移映射与验证。
• 安全：配置双集群的认证与授权；限制复制的主题集合与 ACL。
• 观测：监控复制滞后与错误；在演练中验证切换路径与一致性。

实战清单

• 配置并启动源/目标复制连接器；明确主题选择与命名策略。
• 演练偏移同步与故障切换；文档化切换步骤与回退路径。
• 建立复制健康与滞后监控；持续优化与限制范围。
• Importance: 以标准化复制与偏移治理支持多集群容灾与迁移。