消息队列RocketMQ版重试时间MaxReconsumeTimes的含义是什么?

消息队列RocketMQ版重试时间MaxReconsumeTimes的含义是什么?

展开
收起
Lee_tianbai 2021-01-01 23:23:13 5523 分享 版权
1 条回答
写回答
取消 提交回答
  • 含义:consumer 客户端参数, 最大重试次数,超过最大重试次数,消息将被转 移到私信队列。 作用域:无序和顺序的集群消费起作用。 设置方式:默认值 无序消息 16 次,顺序消息 -1 表示无限次本地重试。 image.png 原理:设置在 consumer 端,如何起作用呢? 消息在消费失败重试时会发送回给 broker,会发回 broker 端,MaxReconsumeTimes 的值就会在请求头内设置。 Broker 接受后的处理会把消息的 topic 改成死信队列的 topic,然后进行存储。

    2021-01-01 23:23:49
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

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