rocketmq重试

使用rocketmq时,发现个问题,就是每次重启项目都会重复消费以前的消息,即便消费时直接返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS也仍是消费不成功,查看rocketmq-console时发现,difftotal时一直存在的,也就是说rocketmq认为是没有消费成功的。后来查看各类资料发现,rocketmq服务端和代码中的mqclient包必须保证一致
相关文章
相关标签/搜索