search

LioRoger / subscribe_example

subscribe from dts data store
63 stars 76 forks source link

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

Open chang19931127 opened 4 years ago

chang19931127 commented 4 years ago

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

dendi875 commented 2 years ago

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

dendi875 commented 2 years ago

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

Wangdali123 commented 1 year ago

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