【转载】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被覆盖的情况。