rocketmq-console 的源码来解开其采集逻辑。 得知，【消费者】界面查询各个消费组的基本信息的接口为 /consumer/groupList. query，那接下来，我们首先从源码的角度来分析该接口的实现逻辑。其入口如下： org.apache.rocketmq.console.controller.ConsumerController#list @RequestMapping(value RocketMQ 一个新的消费组初次启动时从何处开始消费呢？ < 68 令人意外的是，竟然从队列的最小偏移量开始消费了，这就“尴尬”了。难不成是 RocketMQ 的 Bug。带着这个疑问，从源码的角度尝试来解读该问题，并指导我们实践。 二、探究 CONSUME_FROM_MAX_OFFSET 实现原理 对于一个新的消费组，无论是集群模式还是广播模式都不会存储该消费组的消费进度， 可以理解为-1 ，这样该集群内的消息轨迹数据 只会发送到这一台 Broker 服务器上，并不会增加集群内原先业务 Broker 的负载压力。 RocketMQ 消息轨迹的设计细节就介绍到这里了，下一篇将从源码的角度对其实现细 节进行详细的剖析；如果觉得本文对您有帮助的话，期待您的点赞，谢谢。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 155 > 1.17 消息发送常见问题与解决方案