rocketmq重試

使用rocketmq時,發現個問題,就是每次重啓項目都會重複消費以前的消息,即便消費時直接返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS也仍是消費不成功,查看rocketmq-console時發現,difftotal時一直存在的,也就是說rocketmq認爲是沒有消費成功的。後來查看各類資料發現,rocketmq服務端和代碼中的mqclient包必須保證一致
相關文章
相關標籤/搜索