博客

重试队列介绍

对于需要重试消费的消息，并不是Consumer在等待一个指定时长后再去拉取原来的消息进行消费，而是将这些需要重试的消息放入到一个特殊的Topic队列中，而后进行再次消费的，这个特殊的队列就是重试队列。当出现需要进行重试消费的消息时，Broker会为每个消费组都设置Topic名称，为%RETRY%consumerGroup@consumerGroup的重试队列。

这个重试队列是针对消息才组的，而不是针对每个Topic设置的(一个Topic的消息可以让多个消费者进行消费，所以会为这些消费者组各创建一个重试队列)

只有当现在需要进行重试消费的消息时，才会为该消费者组创建重试队列

Broker对于重试消息的处理是通过延迟消息来实现的，先将消息保存到SCHEDULE_TOPIC_XXXX延迟队列中，延迟时间到后，会将消息投递到%consumerGroup@consumerGroup重试队列中。