Strimzi MirrorMaker2主题重新启动/重置



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

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

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

谢谢!

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

最新更新