问题描述
我使用的是 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 (将#修改为@)