如何使用MirrorMarker 2.0 RemoteClusterUtils.translateOffset() 接口在spring kafka 中寻找偏移量?

问题描述

我使用的是 spring-kafka 版本 2.4.12.RELEASE 并且想使用 Mirror Marker 2.0 RemoteClusterUtils.translateOffset() 接口(https://kafka.apache.org/24/javadoc/org/apache/kafka/connect/mirror/RemoteClusterUtils.html)来寻求由它写入的偏移量。

RemoteClusterUtils.translateOffset() :将远程消费者组的偏移量转换为相应的本地偏移量。

用这个在spring-kafka中寻求抵消的方法是什么? 此接口将在故障转移期间使用

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)