You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/07/08 01:48:56 UTC

[GitHub] [rocketmq-flink] ShannonDing commented on issue #19: Direct new DefaultMQPullConsumer, cann't update offset to broker when notifyCheckpointComplete function

ShannonDing commented on issue #19:
URL: https://github.com/apache/rocketmq-flink/issues/19#issuecomment-1178447251

   > 我是自己在那上面改的，自己维护的
   > […](#)
   > ---- 回复的原邮件 ---- | 发件人 | Alan ***@***.***> | | 日期 | 2022年05月18日 16:51 | | 收件人 | ***@***.***> | | 抄送至 | ***@***.******@***.***> | | 主题 | Re: [apache/rocketmq-flink] Direct new DefaultMQPullConsumer, cann't update offset to broker when notifyCheckpointComplete function (Issue #19) | 用这个。而且老版本的由于依赖自动消费队列均衡机制，可能在重启消费的时候，发生数据重复消费的情况。这种在启动之前分配好消费哪个queue，可以避免 … emm... 你说的是用哪个？我现在使用的是 [da92a64](https://github.com/apache/rocketmq-flink/commit/da92a64a12f4de3b352f29182a4565cc4ac23ae4) （2021.1.21）这个版本，最后一个支持flink1.10的版本，在这个版本中，我无论使用checkpoint模式还是用非checkpoint模式，都会遇到offset没有正确提交的问题 — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you w
 ere mentioned.Message ID: ***@***.***>
   
   Hi，Could you pls create a PR to fix this issue?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org