Strimzi MirrorMaker2 主题重启/重置

Question

我们正在使用 Strimzi MirrorMaker2 CRD 将数据从一个 Kafka 集群复制到另一个集群。 复制现在已同步，我注意到一个主题（具有 3 个分区）的主题偏移不正确，源的消息比目标​​多。

我想做的是重新启动 MM2 中的单个主题，而不会影响任何正在同步的主题。我在文档中看不到如何仅重新启动一个主题，可以吗？

我们同步了大约 12 个主题，理想情况下，这些主题不会受到重启的影响。

谢谢！

Answer 1

我不认为 Mirror Maker 2 允许您仅针对一个主题重新启动。它作为几个不同的 Kafka Connect 连接器运行，它们执行不同的任务。但是他们没有任何每个主题的实例。您可以使用this 重新启动连接器或使用this 重新启动任务。但是您不能选择特定的主题，因为每个任务都会处理多个主题。