apache-kafka - Kafka MirrorMaker - 不复制主题的删除

Question

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

谢谢

Answer 1

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

有几个原因：

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

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