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/05/18 05:38:58 UTC

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

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

   用这个。而且老版本的由于依赖自动消费队列均衡机制，可能在重启消费的时候，发生数据重复消费的情况。这种在启动之前分配好消费哪个queue，可以避免
   
   
   
   ---- 回复的原邮件 ----
   | 发件人 | Alan ***@***.***> |
   | 日期 | 2022年05月17日 10:20 |
   | 收件人 | ***@***.***> |
   | 抄送至 | ***@***.******@***.***> |
   | 主题 | Re: [apache/rocketmq-flink] Direct new DefaultMQPullConsumer, cann't update offset to broker when notifyCheckpointComplete function (Issue #19) |
   
   @wangyongchun8888 , do you have the example to reproduce the problem you mentioned?
   
   我也遇到了相同的问题，你后来解决了吗？
   
   —
   Reply to this email directly, view it on GitHub, or unsubscribe.
   You are receiving this because you were mentioned.Message ID: ***@***.***>


-- 
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