源和目标集群中相同主题名称的 Kafka Mirror Maker

Question

我想在源集群和目标集群之间设置 kafka MM2。我的用例是我可以成功地从源集群主题“test”镜像到目标集群主题“test”（没有集群名称前缀）。

现在我想要从源集群主题“test”到目标集群主题“xyx”的镜像（没有集群名称前缀）。任何线索将不胜感激？

你好，

我想在具有不同主题名称的源集群和目标集群之间设置 kafka MM2。

Answer 1

MirrorMaker 使用复制策略来确定远程主题的名称。默认复制策略将源集群别名作为前缀注入远程主题。

MirrorMaker 还有另一个保留主题名称的复制策略，称为IdentityReplicationPolicy。

为了使用它，您需要将 MirrorMaker 配置中的 replication.policy.class 设置为 org.apache.kafka.connect.mirror.IdentityReplicationPolicy。