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 2021/12/16 02:16:51 UTC

[GitHub] [rocketmq] MatrixHB commented on issue #3653: How to deal with consumption failure，when I use DefaultLitePullConsumer

MatrixHB commented on issue #3653:
URL: https://github.com/apache/rocketmq/issues/3653#issuecomment-995377418


   In 4.6.60 version, add lite pull consumer support for RocketMQ：
   (1) Support consume messages in subscribe way with auto rebalance.
   (2) Support consume messages in assign way with no auto rebalance support.
   (3) Add seek/commit offset for a specified message queue.
   
   DefaultLitePullConsumer can be regarded as improved version of DefaultMQPullConsumer, so it is still message pull mode, and you need to implement consumption retry by yourself. Like using kafka, you can seek specific offset in message queue for retry.
   
   Only DefaultMQPushConsumer in CLUSTERING model providers consumption retry machanism.
   
   


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