RocketMQ中registerMessageListener内能否获取消费者组名？

问题背景 #

当前使用的RocketMQ客户端依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.9.1</version>
</dependency>

在并发消费监听器MessageListenerConcurrently的consumeMessage方法中，ConsumeConcurrentlyContext仅暴露了消息队列、延迟级别等和单次消费请求相关的字段，没有直接提供获取消费者组名的入口。

可用实现方式 #

方式1：通过外部消费者实例直接获取（生产推荐） #

只要将注册监听器时持有的DefaultMQPushConsumer实例声明为final，就可以在匿名内部类的消费逻辑中直接调用实例方法获取组名，不存在版本兼容问题：

// 声明为final保证匿名内部类可访问
final DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("your-target-group");
// 省略consumer的nameServer、订阅关系等配置
consumer.registerMessageListener(new MessageListenerConcurrently() {
    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
        for (MessageExt message : msgs) {
            String params = new String(message.getBody(), StandardCharsets.UTF_8);
            ObjectMapper mapper = new ObjectMapper();
            try {
                Map<String, Object> parameters = mapper.readValue(params, Map.class);
                String messageTopic = context.getMessageQueue().getTopic();
                // 直接获取消费者组名
                String consumerGroup = consumer.getConsumerGroup();
            } catch (JsonProcessingException e) {
                throw new RuntimeException(e);
            }
        }
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
    }
});
consumer.start();

方式2：从消息扩展属性中获取（无需持有consumer实例） #

RocketMQ 4.x版本客户端在投递消息到消费逻辑前，会自动给每条MessageExt附加内部属性，其中就包含当前消费者的组名，可以直接通过固定key读取：

// 在遍历消息的逻辑中，直接从消息属性取值
String consumerGroup = message.getProperty(MessageConst.PROPERTY_CONSUMER_GROUP);

注意：该属性属于客户端内部埋点字段，官方未在公开API文档中承诺永久兼容，若使用二次修改的RocketMQ客户端可能存在字段缺失问题。

注意事项 #

• 不建议通过反射读取ConsumeConcurrentlyContext内部持有的非公开字段来获取消费者组，不同小版本的客户端内部字段命名、持有逻辑可能调整，版本升级时容易出现线上故障。
• ConsumeConcurrentlyContext本身定位是传递单次消费请求的可变上下文，仅存储和当前拉取批次、消息队列相关的请求级参数，消费者组属于消费者实例的全局固定配置，因此没有被纳入context的公开字段中。

内容的提问来源于stack exchange，提问作者Dolphin