我正在制作卡夫卡镜子,我正在使用 MM2。我可以启动镜像过程,并且所有主题和日期都从源集群复制到目标集群。
我需要在目标集群中启动消费者,从它在源集群中停止的位置开始。我遇到了 RemoteClusterUtils.translateOffsets 将消费者偏移量从远程转换为本地。
在检查代码时,我可以看到它只是使用检查点主题并返回我们提供的消费者组的偏移量,并且它没有提交偏移量。
我们是否需要使用 OffsetCommitRequest 显式提交偏移量并在目标集群中启动消费者,或者是否需要其他方式?