Vimo's Blog - RocketMQ
type: channel
link: https://blog.vimo.cloud/tag/RocketMQ/
items: RocketMQ同一个消费者内消费者订阅不同Topic问题分析

RocketMQ同一个消费者内消费者订阅不同Topic问题分析
type: item
date: 2023-12-06T14:56:00+08:00
description: 【转载】https://blog.csdn.net/weixin_35973945/article/details/118298429背景在一个服务里起了两个消费者，并且这两个消费者属于同一个组，但是这两个消费者所订阅的Topic是不相同的，出现了只有一个消费者在消费消息，另外一个不消费消息分析经过走查broker端代码发现如下代码：重点在步骤4和5.1和5.2，现在只针对一个broker做一下分析：假设consumer1先启动，对于broker_a一开始关系是group1->topic1当consumer2启动并rebalance完成后，consumer2发送group1->topic2,在步骤4，会根据group1将原先的group1->topic1取出。在步骤5.1，添加topic2在步骤5.2，移除topic1。总结RocketMQ是支持一个消费者订阅多个topic，需要保证组内的消费者订阅的topic都必须一致，否则就会出现订阅的topic被覆盖的情况。