Kafka MirrorMaker - 删除主题不会被复制

Question

我已设置 MirrorMaker2 来复制 2 个 Apache Kafka 集群。一切似乎都进展顺利。我唯一的问题是，当从CLUSTER1中删除主题（在 cluster2 上复制为CLUSTER1.topic）时，cluster2 上的复制主题CLUSTER1.topic不会被删除。因此，主题的删除似乎不会复制到另一个集群.mm2.properties 上有一些特定的属性可以控制主题的复制删除吗？

谢谢

Answer 1

这是预期的行为。MirrorMaker2 不会删除主题或组。

有以下几个原因：

• 这可以防止在错误删除主题时丢失数据。在这种情况下，远程集群上的副本仍然可用。
• 集群可以由不同的团队操作/使用。不再需要某个主题的团队不一定在远程集群上也不再需要该主题。
• 卡夫卡不跟踪主题的“所有权”（谁创建了它）。名称与 MirrorMaker2 规则匹配的主题可能存在于远程集群上，但它不是 MirrorMaker2 副本。

为了避免任何这些问题，目前（如果社区同意，可以更改），MirrorMaker2 不会删除远程集群上的资源。