学习环境搭建指南篇 Step2：namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStar tup 设置环境变量 ROCKETMQ_HOME，操作步骤如下图所示： 设置环境变量名称：ROCKETMQ_HOME，其值用于指定 RocketMQ 运行的主目 录，笔者设置的路径为：/home/dingwpmz/tmp/rocketmq。 本文 autoCreateTopicEnable=true Step7：broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup 设置 环境变量 ROCKETMQ_HOME，操作步骤如下图所示： Step8：以 Debug 模式运行 BrokerStartup，其运行结果如下图所示： 看到这样的提示就表示大功告成。 本文来自『中间件兴 axRatio() / 100.0)); // @2 getResult.setSuggestPullingFromSlave(diff > memory); // @3 代码@1：首先介绍一下几个局部变量的含义：  maxOffsetPy 当前最大的物理偏移量。返回的偏移量为已存入到操作系统的 PageCache 中的内容。  maxPhyOffsetPulling 本次消息拉取最大物理

一：consumer 启动流程 指定 group 订阅 topic 注册消息监听处理器，当消息到来时消费消息 消费端 Start 复制订阅关系 初始化 rebalance 变量 构建 offsetStore 消费进度存储对象 启动消费消息服务 向 mqClientFactory 注册本消费者 启动 client 端远程通信 启动定时任务

下面可以挂载多个 Slave，同一 Master 下的多个 Slave 通过挃 定丌同的 BrokerId 来区分。 $ROCKETMQ_HOST 挃的 RocketMQ 安装目录，需要用户自己设置此环境变量。 项目开源主页：https://github.com/alibaba/RocketMQ 40 12.3 Broker 重启对客户端的影响 Broker 重启可能会导致正在収往返台机器的的消息収送失败，RocketMQ