第 8 章使用带有 MirrorMaker 2.0 的 AMQ Streams

使用 MirrorMaker 2.0 在两个或更多活跃 Kafka 集群之间复制数据，并在数据中心之间复制数据。

集群中的数据复制支持需要的情况：

要配置 MirrorMaker 2.0，请编辑 config/connect-mirror-maker.properties 配置文件。

处理大量消息

您可以调整配置来处理大量消息。更多信息请参阅第 9 章 处理大量消息。

注意

MirrorMaker 2.0 具有之前版本的 MirrorMaker 不支持的功能。但是，您可以将 MirrorMaker 2.0 配置为用于传统模式。

8.1. MirrorMaker 2.0 数据复制
复制链接

MirrorMaker 2.0 使用来自源 Kafka 集群的信息，并将其写入目标 Kafka 集群。

MirrorMaker 2.0 使用：

MirrorMaker 2.0 基于 Kafka Connect 框架，连接器 管理集群之间的数据传输。

MirrorMaker 2.0 使用以下连接器：

镜像从一个集群镜像到另一个集群的过程是异步的。推荐的模式是在本地和源 Kafka 集群一起生成信息，然后远程消耗到目标 Kafka 集群。

MirrorMaker 2.0 可以和多个源集群一起使用。

图 8.1. 在两个集群间复制

默认情况下，每隔 10 分钟对源集群中的新主题进行一次检查。您可以通过在源连接器配置中添加 refresh.topics.interval.seconds 来更改频率。但是，增加操作的频率可能会影响整体性能。

返回顶部