| 形态 | Connect 框架上的 Connector，运行于源/目标集群 |
|---|---|
| 主题命名 | 默认给复制主题加源集群前缀，避免冲突 |
| 容灾 | 同步消费组位移与心跳，支持切换后继续消费 |
mm2.properties 关键片段
mm2.properties 关键片段
clusters = src, dst
src.bootstrap.servers = kafka-src:9092
dst.bootstrap.servers = kafka-dst:9092
src->dst.enabled = true
src->dst.topics = orders.*
replication.factor = 3
checkpoints.topic.replication.factor = 3
heartbeats.topic.replication.factor = 3启动与查看
启动与查看
connect-mirror-maker.sh config/mm2.properties
# 复制进度可在 Connect REST 或心跳主题查看每个集群要设置唯一的 cluster alias；双向复制时必须排除心跳、检查点、位移等内部主题，避免回环。