1

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

我想做的是在 MM2 中重新启动该单个主题,而不影响任何正在同步的主题。我在文档中看不到如何仅重新启动一个主题,这可能吗?

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

谢谢!

4

1 回答 1

1

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

于 2021-03-26T09:21:05.927 回答