当我使用DefaultLitePullConsumer时,如何处理消费失败

当我使用DefaultLitePullConsumer时,如何处理消费失败

原提问者GitHub用户Cczzzz

展开
收起
芬奇福贵 2023-05-26 10:38:32 185 分享 版权
1 条回答
写回答
取消 提交回答
  • 在4.6.60版本中,添加了对RocketMQ的lite-pull消费者支持: (1) 通过自动重新平衡,支持以订阅方式消费消息。 (2) 支持以分配方式使用消息,不支持自动重新平衡。 (3) 为指定的消息队列添加查找/提交偏移量。

    DefaultLitePulConsumer可以被视为DefaultMQPullConsumer的改进版本,因此它仍然是消息拉取模式,您需要自己实现消费重试。像使用kafka一样,您可以在消息队列中查找特定的偏移量以进行重试。

    只有CLUSTERING模型中的DefaultMQPushConsumer提供程序消耗重试机制。

    原回答者GitHub用户MatrixHB

    2023-05-26 16:56:23
    赞同 展开评论
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理