我在做Kafka的镜子,我在用mm2。我可以启动镜像进程,所有主题和日期都从源集群复制到目标集群。
我需要在目标集群中从源集群中停止的地方启动消费者。我遇到了remoteclusterutils.translateoffsets来将使用者偏移量从远程转换到本地。
在检查代码时,我可以看到它只使用检查点主题并返回我们提供的使用者组的偏移量,而不提交偏移量。
我们是否需要使用offsetcommitrequest显式地提交偏移量并在目标集群中启动使用者,或者是否需要其他方法来实现这一点?
我在做Kafka的镜子,我在用mm2。我可以启动镜像进程,所有主题和日期都从源集群复制到目标集群。
我需要在目标集群中从源集群中停止的地方启动消费者。我遇到了remoteclusterutils.translateoffsets来将使用者偏移量从远程转换到本地。
在检查代码时,我可以看到它只使用检查点主题并返回我们提供的使用者组的偏移量,而不提交偏移量。
我们是否需要使用offsetcommitrequest显式地提交偏移量并在目标集群中启动使用者,或者是否需要其他方法来实现这一点?
暂无答案!
目前还没有任何答案,快来回答吧!