subscrib 模式下无法重置提交位点

[chang19931127]

如图
不知道是自己理解问题，还是代码阅读能力较差，目前发现 subscrib 模式下无法重置消费问题，请求大牛帮助

[dendi875]

subscrib 模式如果要使用自定义的初始化检查点可以这样：
kafkaConsumerWrap.subscribeTopic(topicPartition, () -> {
return initialCheckpoint;
});
但这样每次发版或重启后都会从这个检查点开始消费，会造成重复消费

[dendi875]

subscrib 模式如果要使用自定义的初始化检查点可以这样：
kafkaConsumerWrap.subscribeTopic(topicPartition, () -> {
return initialCheckpoint;
});
但这样每次发版或重启后都会从这个检查点开始消费，会造成重复消费

[Wangdali123]

。。。。看官网这描述 initCheckpoint只在ASSIGN模式下且 setForceUseCheckpoint=true 才起作用