来源和目标集群中相同主题名称的Kafka镜像制造者

Question

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

现在，我希望镜像从源集群主题"test“到目标集群主题"xyx”(没有集群名称的前缀)。有什么线索会很感激吗？

嗨,

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

Answer 1

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

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

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