java技术圈 为您找到相关结果 1

RocketMQ消息积压-订阅关系不一致

--- ### 一、订阅关系不一致的场景 1. **消费组内不同消费者订阅不同Tag** 例如,消费组中有两个消费者: • 消费者A订阅Topic为`OrderTopic`,Tag为`tagA`; • 消费者B订阅同一Topic`OrderTopic`,但Tag为`tagB`。 此时,消息发送者向`OrderTopic`发送不同Tag的消息(如`tagA`和`tagB`),消息会均匀分布到Topic的各个队列中。但消费者A和B各自只能消费特定Tag的消息,导致**部分消息被过滤后未被投递**,最终积压。 2. **队列分配与消息过滤的冲突** • RocketMQ默认采用队列平均分配策略:若Topic有4个队列,消费者A分配到队列0和1,消费者B分配到队列2和3。 • 如果消费者A只订阅`t...阅读全文