2

MirrorMaker2 (strimzi:0.22.1-kafka-2.7.0) 配置为在启用组偏移同步的情况下从代理 A 到 B 进行一次定向镜像：

sync.group.offsets.enabled: true
sync.group.offsets.interval.seconds: 30

当源代理 A 上的一个节点在一段时间内不可用时，设置工作正常。从那时起，偏移量停止同步，并且延迟仅在目标代理 B 上增长，因为主题仅从源代理 A 消费。所以现在的问题是组偏移量停止同步。

到目前为止尝试了什么：

  • 重新启动任务（无效）
  • 重新启动 MirrorMaker2（无效）
  • 重置目标代理 B 上的偏移量（偏移量没有同步，滞后只是在增长）
  • 从目标代理 B 中删除组 ID（未在目标上重新创建组 ID）
  • 删除主题（然后重新创建主题，而不是消费者组或偏移量开始同步）
  • 禁用偏移同步并再次启用它（无效）

似乎破碎的消费者群体仍然存在于内部主题中，并阻止重新创建/重新同步这些主题。

有没有办法在不重新创建代理的情况下重新同步特定主题或 groupId？

4

0 回答 0