Kafka Cluster Linking vs MirrorMaker
Confluent平台的Cluster Linking与开源MirrorMaker 2相比有哪些差异？请从架构设计、延迟控制、灾难恢复、元数据同步、Exactly-Once保障等维度进行对比说明。Cluster Linking的异步/双向模式如何工作？
回答
苦行僧
1. 架构差异
| 维度 | Cluster Linking | MirrorMaker 2 |
|---|---|---|
| 工作方式 | Broker层连接 | Client层消费-生产 |
| 部署位置 | Broker内部 | 独立Connect集群 |
| 数据路径 | 存储层直接复制 | 消费者→生产者管道 |
| 运维复杂度 | 低（内建） | 较高（外部服务） |
2. 核心优势
低延迟
- Cluster Linking在Broker内部完成，不经过客户端栈
- 最小延迟可达ms级（MM2通常秒级）
Exactly-Once语义
// Cluster Linking利用事务机制
// 幂等生产者 + 事务协调器
// 保证源分区与目标分区数据顺序一致
元数据同步
- Topic/分区/配置变更自动同步（最终一致）
- 支持Schema Registry同步
- ACL同步内置支持
3. 同步模式
异步模式（Active-Active）
# 两个集群互相同步
# 数据最终一致
# 适合：地理分布式多活架构
双向同步防冲突
- 每条消息带有起源集群标签
- 冲突解决策略：
- 按时间戳
- 按Cluster ID优先级
- 自定义策略
4. 灾难恢复场景
- Cluster Linking支持自动重连
- 断连后自动追赶上
- 配合Confluent Fleet Management实现自动故障转移
5. 局限性
- Confluent企业版功能（非开源）
- 仅支持Confluent Platform
- 配置复杂度在超大规模集群中增加
- 不支持同步消费组偏移量（需额外工具）