第 9 章 使用带有 MirrorMaker 2.0 的 AMQ Streams
MirrorMaker 2.0 用于在数据中心内或之间的两个或多个活跃 Kafka 集群之间复制数据。
集群间的数据复制支持以下条件：
- 发生系统故障时恢复数据
- 聚合数据以进行分析
- 对特定集群的数据访问的限制
- 在特定位置置备数据以缩短延迟
注意
MirrorMaker 2.0 具有以前版本的 MirrorMaker 不支持的功能。但是，您可以将 MirrorMaker 2.0 配置为在旧模式中使用。
9.1. MirrorMaker 2.0 数据复制
MirrorMaker 2.0 使用源 Kafka 集群的信息，并将其写入目标 Kafka 集群。
MirrorMaker 2.0 使用：
- 源集群配置以使用源集群的数据
- 将数据输出到目标集群的目标集群配置
MirrorMaker 2.0 基于 Kafka Connect 框架，即管理集群间数据传输的 连接器。MirrorMaker 2.0 MirrorSourceConnector 将源集群中的主题复制到目标集群。
将数据从一个集群 镜像 到另一个集群的过程是异步的。建议的模式是让信息与源 Kafka 集群一起生成，然后远程使用与目标 Kafka 集群类似的信息。
MirrorMaker 2.0 可以用于多个源集群。
图 9.1. 在两个集群间复制
默认情况下，每 10 分钟检查源集群中的新主题。您可以通过在源连接器配置中添加 refresh.topics.interval.seconds 来更改频率。但是，增加操作的频率可能会影响整体性能。
