消息的衰减重试
為了保證消息肯定至少被消費一次,RocketMQ會把這批消息重新發回到broker,在延遲的某個時間點(默認是10秒,業務可設置)后,再次投遞到這個ConsumerGroup。而如果一直這樣重復消費都持續失敗到一定次數(默認16次),就會投遞到DLQ死信隊列。應用可以監控死信隊列來做人工干預
可以修改broker-a.conf文件
messageDelayLevel = 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
?
總結
- 上一篇: 消息消费端的确认机制
- 下一篇: 重试消息的处理机制