RocketMQ创建消费组

### 如何在 RocketMQ 中创建消费组

在 RocketMQ 中，消费组的概念用于管理一组消费者的逻辑集合。通过配置消费组名称，可以在多个实例之间共享消息处理负载并确保高可用性和扩展性。

#### 配置消费者应用中的消费组名

为了指定一个消费组，在编写基于 Spring Boot 的应用程序时，可以通过 `@RocketMQMessageListener` 注解来声明监听器类，并设置其属性 `consumerGroup` 来定义所属的消费组[^1]：

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.stereotype.Service;

@Service
@RocketMQMessageListener(
    topic = "TestTopic", 
    consumerGroup = "test_consumer_group"
)
public class TestConsumer {
    
}

上述代码片段展示了如何在一个服务组件上标记特定的主题和消费组关联方式。

#### 启动消费者后自动注册订阅关系

当新的消费者首次启动时会向 NameServer 报告自身的存在以及所关心的消息主题列表；此时如果该消费组尚未存在于集群内，则会被动态创建出来。因此不需要预先手动建立任何消费组——它们会在第一次有成员加入的时候自动生成[^3]。

需要注意的是，对于已经存在的消费组而言，新加入的节点将会遵循既定策略参与再平衡过程分配待处理的任务集。

#### 处理多实例下的消费行为

在同一消费组内的所有活动参与者共同负责完成整个队列里的工作项分发任务。这意味着即使是在分布式环境中部署了大量相同类型的接收端程序副本，只要这些都指定了相同的 group ID 就能协同合作而不会重复读取同一条记录多次[^2]。