Windows 10 本地部署 RocketMQ 5.3.3 全流程指南：RocketMQ 下载、本地部署、RocketMQ Dashboard 2.0.0
·
1. 概述
本文详细介绍了在Windows 10环境下部署RocketMQ 5.3.3的完整过程。系统配置为8G内存+JDK21环境。下载并使用RocketMQ二进制发布包部署。重点说明了环境变量ROCKETMQ_HOME的设置方法，以及如何启动NameServer服务，如何启动Broker，如何启动控制台RocketMQ Dashboard 2.0.0。
注意：本文在Windows环境下部署RocketMQ，用于快速测试验证，仅适用于开发和测试环境。在生产环境，请使用高可用的部署方案。
2. 本地部署环境
- 操作系统：Windows 10
- 内存：8G
- JDK：21
Windows硬件配置：
3. 下载安装 RocketMQ
3.1. 官网下载
官方文档下载地址：https://rocketmq.apache.org/zh/download
本文下载的 RocketMQ 是截止【2025-08-03】的最新版【5.3.3】。
- 【Source】：是源码包，源码包是需要编译后运行的。
- 【Binary 】：是二进制包，二进制包是已经编译完成后可以直接运行的。本文下载的就是此版本。
下载后的 RocketMQ 二进制发布包：
3.2. 解压到本地磁盘
RocketMQ 二进制发布包，将其解压到本地磁盘 D:\rocketmq 。
解压后的二进制发布包，完整安装路径：D:\rocketmq\rocketmq-all-5.3.3-bin-release 。
应用内部目录结构如下：
4. 本地部署 RocketMQ
4.1. 官方文档参考
官方文档的 《本地部署 RocketMQ》 章节提供了详细的安装指南，但其示例环境为 Linux 系统，使用的是社区版 5.3.2 的源码包进行编译安装。
4.2. 基于 README.md 的 Windows 部署指南
由于本文的部署环境是 Windows 10，并且我们下载的是无需编译的二进制发布包 (Binary Release)，因此我们将严格遵循 RocketMQ 解压包内自带的《README.md》文档进行操作。这是针对当前版本 (5.3.3) 和二进制包最直接的指引。
- 定位文档： 解压后，在 RocketMQ 根目录 (如
D:\rocketmq) 下可以找到README.md文件。 - 查阅指南： 在文件资源管理器中双击
README.md文件（通常会用系统默认的 Markdown 阅读器或文本编辑器打开）。本文后续使用Edge浏览器打开该文档，markdown-viewer插件渲染。 - 语言辅助 (可选)： 为了便于理解英文文档，在浏览器中打开该文件并使用浏览器的翻译功能将其转换为中文，本文使用的是Edge浏览器翻译插件
沉浸式翻译。
(图片示意：展示 README.md 文件在解压目录中的位置)
4.3. 检查Java环境变量
RocketMQ需要Java运行环境的支持，检查Java环境变量是否已经配好。
本例中Java运行环境是 OracleJDK-21 。
D:\>java -version
java version "21.0.1" 2023-10-17 LTS
Java(TM) SE Runtime Environment (build 21.0.1+12-LTS-29)
Java HotSpot(TM) 64-Bit Server VM (build 21.0.1+12-LTS-29, mixed mode, sharing)
4.4. 准备终端并切换到解压后的 bin 目录
bin 目录：
4.5. 启动 NameServer
4.5.1. 未设置环境变量 ROCKETMQ_HOME 报错
默认启动，提示需要设置环境变量：ROCKETMQ_HOME 。
D:\rocketmq\rocketmq-all-5.3.3-bin-release\bin>mqnamesrv.cmd
Please set the ROCKETMQ_HOME variable in your environment!
4.5.2. 设置环境变量 ROCKETMQ_HOME
- 打开环境变量配置界面：右键点击【此电脑】→【属性】→【高级系统设置】→【环境变量】。
- 新建系统变量（所有用户生效）：在【系统变量】区域点击【新建】，输入变量名和变量值。
变量名：
ROCKETMQ_HOME
变量值：
D:\rocketmq\rocketmq-all-5.3.3-bin-release
4.5.3. 启动 NameServer
执行命令：
mqnamesrv.cmd
注意：在设置环境变量 ROCKETMQ_HOME 后，需要重新打开命令行窗口，才能重新加载环境变量；否则，新设置的环境变量还会找不到。
经过几秒后，启动成功，打印日志：
D:\rocketmq\rocketmq-all-5.3.3-bin-release\bin>mqnamesrv.cmd
The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
4.5.4. NameServer日志
验证 NameServer 是否启动成功，查看日志 namesrv.log：
日志位置：
C:\Users\<用户名>\logs\rocketmqlogs\namesrv.log
日志内容：
2025-08-10 03:44:39 INFO main - rocketmqHome=D:\rocketmq\rocketmq-all-5.3.3-bin-release
2025-08-10 03:44:39 INFO main - kvConfigPath=C:\Users\<用户名>\namesrv\kvConfig.json
2025-08-10 03:44:39 INFO main - configStorePath=C:\Users\<用户名>\namesrv\namesrv.properties
2025-08-10 03:44:39 INFO main - productEnvName=center
2025-08-10 03:44:39 INFO main - clusterTest=false
2025-08-10 03:44:39 INFO main - orderMessageEnable=false
2025-08-10 03:44:39 INFO main - returnOrderTopicConfigToBroker=true
2025-08-10 03:44:39 INFO main - clientRequestThreadPoolNums=8
2025-08-10 03:44:39 INFO main - defaultThreadPoolNums=16
2025-08-10 03:44:39 INFO main - clientRequestThreadPoolQueueCapacity=50000
2025-08-10 03:44:39 INFO main - defaultThreadPoolQueueCapacity=10000
2025-08-10 03:44:39 INFO main - scanNotActiveBrokerInterval=5000
2025-08-10 03:44:39 INFO main - unRegisterBrokerQueueCapacity=3000
2025-08-10 03:44:39 INFO main - supportActingMaster=false
2025-08-10 03:44:39 INFO main - enableAllTopicList=true
2025-08-10 03:44:39 INFO main - enableTopicList=true
2025-08-10 03:44:39 INFO main - notifyMinBrokerIdChanged=false
2025-08-10 03:44:39 INFO main - enableControllerInNamesrv=false
2025-08-10 03:44:39 INFO main - needWaitForService=false
2025-08-10 03:44:39 INFO main - waitSecondsForService=45
2025-08-10 03:44:39 INFO main - deleteTopicWithBrokerRegistration=false
2025-08-10 03:44:39 INFO main - configBlackList=configBlackList;configStorePath;kvConfigPath
2025-08-10 03:44:39 INFO main - bindAddress=0.0.0.0
2025-08-10 03:44:39 INFO main - listenPort=9876
2025-08-10 03:44:39 INFO main - serverWorkerThreads=8
2025-08-10 03:44:39 INFO main - serverCallbackExecutorThreads=0
2025-08-10 03:44:39 INFO main - serverSelectorThreads=3
2025-08-10 03:44:39 INFO main - serverOnewaySemaphoreValue=256
2025-08-10 03:44:39 INFO main - serverAsyncSemaphoreValue=64
2025-08-10 03:44:39 INFO main - serverChannelMaxIdleTimeSeconds=120
2025-08-10 03:44:39 INFO main - serverSocketSndBufSize=0
2025-08-10 03:44:39 INFO main - serverSocketRcvBufSize=0
2025-08-10 03:44:39 INFO main - writeBufferHighWaterMark=0
2025-08-10 03:44:39 INFO main - writeBufferLowWaterMark=0
2025-08-10 03:44:39 INFO main - serverSocketBacklog=1024
2025-08-10 03:44:39 INFO main - serverNettyWorkerGroupEnable=true
2025-08-10 03:44:39 INFO main - serverPooledByteBufAllocatorEnable=true
2025-08-10 03:44:39 INFO main - enableShutdownGracefully=false
2025-08-10 03:44:39 INFO main - shutdownWaitTimeSeconds=30
2025-08-10 03:44:39 INFO main - useEpollNativeSelector=false
2025-08-10 03:44:39 INFO main - Server is running in TLS permissive mode
2025-08-10 03:44:39 INFO main - Tls config file doesn't exist, skip it
2025-08-10 03:44:39 INFO main - Log the final used tls related configuration
2025-08-10 03:44:39 INFO main - tls.test.mode.enable = true
2025-08-10 03:44:40 INFO main - Using OpenSSL provider
2025-08-10 03:44:42 INFO main - SSLContext created for server
2025-08-10 03:44:43 INFO NSScanScheduledThread - start scanNotActiveBroker
2025-08-10 03:44:43 INFO main - RemotingServer started, listening 0.0.0.0:9876
2025-08-10 03:44:43 INFO main - Try to start service thread:NettyEventExecutor started:false lastThread:null
2025-08-10 03:44:43 INFO main - Start service thread:NettyEventExecutor started:true lastThread:Thread[#38,NettyEventExecutor,5,main]
2025-08-10 03:44:43 INFO NettyEventExecutor - NettyEventExecutor service started
2025-08-10 03:44:43 INFO main - name server address updated. NEW : [192.168.56.1:9876] , OLD: null
2025-08-10 03:44:43 INFO main - Try to start service thread:NettyEventExecutor started:false lastThread:null
2025-08-10 03:44:43 INFO main - Start service thread:NettyEventExecutor started:true lastThread:Thread[#40,NettyEventExecutor,5,main]
2025-08-10 03:44:43 INFO main - Try to start service thread:FileWatchService started:false lastThread:null
2025-08-10 03:44:43 INFO main - Start service thread:FileWatchService started:true lastThread:Thread[#41,FileWatchService,5,main]
2025-08-10 03:44:43 INFO main - Try to start service thread:org.apache.rocketmq.namesrv.routeinfo.BatchUnregistrationService started:false lastThread:null
2025-08-10 03:44:43 INFO NettyEventExecutor - NettyEventExecutor service started
2025-08-10 03:44:43 INFO main - Start service thread:org.apache.rocketmq.namesrv.routeinfo.BatchUnregistrationService started:true lastThread:Thread[#42,org.apache.rocketmq.namesrv.routeinfo.BatchUnregistrationService,5,main]
2025-08-10 03:44:43 INFO FileWatchService - FileWatchService service started
2025-08-10 03:44:43 INFO main - The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
2025-08-10 03:44:43 INFO NettyClientScan_thread_1 - createChannel: begin to connect remote host[192.168.56.1:9876] asynchronously
2025-08-10 03:44:43 INFO NettyClientWorkerThread_1 - NETTY CLIENT PIPELINE: CONNECT 192.168.56.1 => 192.168.56.1:9876
2025-08-10 03:44:43 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelRegistered 192.168.56.1:1873
2025-08-10 03:44:43 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelActive, the channel[192.168.56.1:1873]
2025-08-10 03:44:43 INFO NettyClientWorkerThread_1 - NETTY CLIENT PIPELINE: ACTIVE, 192.168.56.1:9876, channelId=feb2ed2b
2025-08-10 03:44:48 INFO NSScanScheduledThread - start scanNotActiveBroker
2025-08-10 03:44:53 INFO NSScanScheduledThread - start scanNotActiveBroker
2025-08-10 03:44:58 INFO NSScanScheduledThread - start scanNotActiveBroker
2025-08-10 03:45:03 INFO NSScanScheduledThread - start scanNotActiveBroker
2025-08-10 03:45:08 INFO NSScanScheduledThread - start scanNotActiveBroker
2025-08-10 03:45:13 INFO NSScanScheduledThread - start scanNotActiveBroker
之所以日志在这个位置，是由于默认配置：
4.6. 启动 Broker
说明文档中给出的启动命令是：mqbroker.cmd -n localhost:9876 。
如果使用此命令，可能导致Broker异常，生产者发送的消息无法正常发送到RocketMQ服务器。因此建议，将Broker 存储路径 设置到非C盘。可以在Broker配置文件中设计存储路径，然后在启动Broker时，通过命令参数指定配置文件。
具体原因，请参考：《SpringBoot3发送RocketMQ消息失败问题排查与解决方案：Windows中RocketMQ的Broker存储路径有问题导致生产者发送消息失败（MQClientException）》
4.6.1. 修改配置文件（broker.conf）
使用配置文件指定存储路径。
4.6.1.1. 存储路径配置
broker.conf 添加 storePathRootDir 配置，指定存储路径：
# 存储根路径
storePathRootDir = D:/rocketmq/store
4.6.1.2. broker.conf 全文配置示例
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# NameServer地址
namesrvAddr = localhost:9876
# 存储根路径
storePathRootDir = D:/rocketmq/store
4.6.1.3. 配置文件中指定NameServer地址
NameServer地址，直接在Broker配置文件中指定，就不需要在启动命令中传入了。
# NameServer地址
namesrvAddr = localhost:9876
4.6.1.4. 路径中必须使用使用正斜杠
注意：路径中必须使用使用正斜杠 /， storePathRootDir = D:/rocketmq/store，否则Broker启动会报错。报错信息如下：
java.lang.NullPointerException: Cannot invoke "org.apache.rocketmq.store.MessageStore.getMessageStoreConfig()" because the return value of "org.apache.rocketmq.broker.BrokerController.getMessageStore()" is null
at org.apache.rocketmq.broker.schedule.ScheduleMessageService.configFilePath(ScheduleMessageService.java:273)
at org.apache.rocketmq.common.ConfigManager.persist(ConfigManager.java:79)
at org.apache.rocketmq.broker.BrokerController.shutdownBasicService(BrokerController.java:1522)
at org.apache.rocketmq.broker.BrokerController.shutdown(BrokerController.java:1618)
at org.apache.rocketmq.broker.BrokerStartup.createBrokerController(BrokerStartup.java:250)
at org.apache.rocketmq.broker.BrokerStartup.main(BrokerStartup.java:52)
4.6.2. 使用配置文件启动Broker
4.6.2.1. 启动命令
在RockerMQ的根目录，启动CMD，使用如下命令启动：
bin\mqbroker.cmd -c conf\broker.conf
4.6.2.2. 启动成功日志
完整日志：
Microsoft Windows [版本 10.0.19045.6332]
(c) Microsoft Corporation。保留所有权利。
D:\rocketmq\rocketmq-all-5.3.3-bin-release>bin\mqbroker.cmd -c conf\broker.conf
20:24:42,582 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.LoggerContext[default] - This is logback-classic version 1.3.5-rocketmq
20:24:42,714 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.LoggerContext[default] - Found resource [D:\rocketmq\rocketmq-all-5.3.3-bin-release\conf\rmq.broker.logback.xml] at [file:/D:/rocketmq/rocketmq-all-5.3.3-bin-release/conf/rmq.broker.logback.xml]
20:24:43,216 |-WARN in org.apache.rocketmq.logging.ch.qos.logback.classic.joran.action.LevelAction - <level> element is deprecated. Near [level] on line 700
20:24:43,216 |-WARN in org.apache.rocketmq.logging.ch.qos.logback.classic.joran.action.LevelAction - Please use "level" attribute within <logger> or <root> elements instead.
20:24:43,426 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.ConfigurationModelHandler - Registering a new ReconfigureOnChangeTask ReconfigureOnChangeTask(born:1759321483426)
20:24:43,428 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.ConfigurationModelHandler - Will scan for changes in [file:/D:/rocketmq/rocketmq-all-5.3.3-bin-release/conf/rmq.broker.logback.xml]
20:24:43,428 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.ConfigurationModelHandler - Setting ReconfigureOnChangeTask scanning period to 30 seconds
20:24:43,440 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [DefaultSiftingAppender_inner]
20:24:43,440 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,472 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,503 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [DefaultSiftingAppender]
20:24:43,503 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,508 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [DefaultSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[DefaultSiftingAppender]
20:24:43,508 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[DefaultSiftingAppender] - Attaching appender named [DefaultSiftingAppender_inner] to AsyncAppender.
20:24:43,509 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[DefaultSiftingAppender] - Setting discardingThreshold to 51
20:24:43,509 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqBrokerSiftingAppender_inner]
20:24:43,509 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,509 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,510 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqBrokerSiftingAppender]
20:24:43,510 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,510 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqBrokerSiftingAppender]
20:24:43,510 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqBrokerSiftingAppender] - Attaching appender named [RocketmqBrokerSiftingAppender_inner] to AsyncAppender.
20:24:43,510 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqBrokerSiftingAppender] - Setting discardingThreshold to 51
20:24:43,511 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqProtectionSiftingAppender_inner]
20:24:43,511 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,511 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,511 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqProtectionSiftingAppender]
20:24:43,511 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,512 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqProtectionSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqProtectionSiftingAppender]
20:24:43,512 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqProtectionSiftingAppender] - Attaching appender named [RocketmqProtectionSiftingAppender_inner] to AsyncAppender.
20:24:43,512 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqProtectionSiftingAppender] - Setting discardingThreshold to 51
20:24:43,512 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqWaterMarkSiftingAppender_inner]
20:24:43,512 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,512 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqWaterMarkSiftingAppender]
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqWaterMarkSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqWaterMarkSiftingAppender]
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqWaterMarkSiftingAppender] - Attaching appender named [RocketmqWaterMarkSiftingAppender_inner] to AsyncAppender.
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqWaterMarkSiftingAppender] - Setting discardingThreshold to 51
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRocksDBSiftingAppender_inner]
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,513 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRocksDBSiftingAppender]
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqRocksDBSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRocksDBSiftingAppender]
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRocksDBSiftingAppender] - Attaching appender named [RocketmqRocksDBSiftingAppender_inner] to AsyncAppender.
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRocksDBSiftingAppender] - Setting discardingThreshold to 51
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqStoreSiftingAppender_inner]
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,514 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqStoreSiftingAppender]
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqStoreSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStoreSiftingAppender]
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStoreSiftingAppender] - Attaching appender named [RocketmqStoreSiftingAppender_inner] to AsyncAppender.
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStoreSiftingAppender] - Setting discardingThreshold to 51
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqTieredStoreSiftingAppender_inner]
20:24:43,515 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqTieredStoreSiftingAppender]
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqTieredStoreSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTieredStoreSiftingAppender]
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTieredStoreSiftingAppender] - Attaching appender named [RocketmqTieredStoreSiftingAppender_inner] to AsyncAppender.
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTieredStoreSiftingAppender] - Setting discardingThreshold to 51
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqTrafficSiftingAppender_inner]
20:24:43,516 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,517 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,517 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqTrafficSiftingAppender]
20:24:43,517 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,517 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqTrafficSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTrafficSiftingAppender]
20:24:43,517 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTrafficSiftingAppender] - Attaching appender named [RocketmqTrafficSiftingAppender_inner] to AsyncAppender.
20:24:43,517 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTrafficSiftingAppender] - Setting discardingThreshold to 51
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRemotingSiftingAppender_inner]
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRemotingSiftingAppender]
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqRemotingSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRemotingSiftingAppender]
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRemotingSiftingAppender] - Attaching appender named [RocketmqRemotingSiftingAppender_inner] to AsyncAppender.
20:24:43,518 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRemotingSiftingAppender] - Setting discardingThreshold to 51
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqStoreErrorSiftingAppender_inner]
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqStoreErrorSiftingAppender]
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqStoreErrorSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStoreErrorSiftingAppender]
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStoreErrorSiftingAppender] - Attaching appender named [RocketmqStoreErrorSiftingAppender_inner] to AsyncAppender.
20:24:43,519 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStoreErrorSiftingAppender] - Setting discardingThreshold to 51
20:24:43,520 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqTransactionSiftingAppender_inner]
20:24:43,520 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,520 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqTransactionSiftingAppender]
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqTransactionSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTransactionSiftingAppender]
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTransactionSiftingAppender] - Attaching appender named [RocketmqTransactionSiftingAppender_inner] to AsyncAppender.
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqTransactionSiftingAppender] - Setting discardingThreshold to 51
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRebalanceLockSiftingAppender_inner]
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,521 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRebalanceLockSiftingAppender]
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqRebalanceLockSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRebalanceLockSiftingAppender]
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRebalanceLockSiftingAppender] - Attaching appender named [RocketmqRebalanceLockSiftingAppender_inner] to AsyncAppender.
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRebalanceLockSiftingAppender] - Setting discardingThreshold to 51
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqFilterSiftingAppender_inner]
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,522 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqRebalanceLockSiftingAppender]
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqFilterSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRebalanceLockSiftingAppender]
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRebalanceLockSiftingAppender] - Attaching appender named [RocketmqFilterSiftingAppender_inner] to AsyncAppender.
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqRebalanceLockSiftingAppender] - Setting discardingThreshold to 51
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqStatsSiftingAppender_inner]
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,524 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqStatsSiftingAppender]
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqStatsSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStatsSiftingAppender]
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStatsSiftingAppender] - Attaching appender named [RocketmqStatsSiftingAppender_inner] to AsyncAppender.
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqStatsSiftingAppender] - Setting discardingThreshold to 51
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqCommercialSiftingAppender_inner]
20:24:43,525 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,526 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,526 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqCommercialSiftingAppender]
20:24:43,526 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,526 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqCommercialSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqCommercialSiftingAppender]
20:24:43,526 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqCommercialSiftingAppender] - Attaching appender named [RocketmqCommercialSiftingAppender_inner] to AsyncAppender.
20:24:43,526 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqCommercialSiftingAppender] - Setting discardingThreshold to 51
20:24:43,527 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqPopSiftingAppender_inner]
20:24:43,527 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,527 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqPopSiftingAppender]
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqPopSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqPopSiftingAppender]
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqPopSiftingAppender] - Attaching appender named [RocketmqPopSiftingAppender_inner] to AsyncAppender.
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqPopSiftingAppender] - Setting discardingThreshold to 51
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqColdCtrSiftingAppender]
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,528 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,529 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqBrokerMetricsSiftingAppender_inner]
20:24:43,529 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,529 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqBrokerMetricsSiftingAppender]
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqBrokerMetricsSiftingAppender]
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqBrokerMetricsSiftingAppender] - Attaching appender named [RocketmqBrokerMetricsSiftingAppender_inner] to AsyncAppender.
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqBrokerMetricsSiftingAppender] - Setting discardingThreshold to 51
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqAuthAuditSiftingAppender_inner]
20:24:43,530 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.SiftingAppender]
20:24:43,531 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.sift.MDCBasedDiscriminator] for [discriminator] property
20:24:43,531 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [RocketmqAuthAuditSiftingAppender]
20:24:43,531 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender]
20:24:43,531 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqAuthAuditSiftingAppender_inner] to org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqAuthAuditSiftingAppender]
20:24:43,531 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqAuthAuditSiftingAppender] - Attaching appender named [RocketmqAuthAuditSiftingAppender_inner] to AsyncAppender.
20:24:43,531 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.AsyncAppender[RocketmqAuthAuditSiftingAppender] - Setting discardingThreshold to 51
20:24:43,532 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [STDOUT]
20:24:43,532 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [org.apache.rocketmq.logging.ch.qos.logback.core.ConsoleAppender]
20:24:43,541 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [org.apache.rocketmq.logging.ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
20:24:43,665 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqBroker] to INFO
20:24:43,665 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqBroker] to false
20:24:43,665 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerSiftingAppender] to Logger[RocketmqBroker]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqProtection] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqProtection] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqProtectionSiftingAppender] to Logger[RocketmqProtection]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqWaterMark] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqWaterMark] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqWaterMarkSiftingAppender] to Logger[RocketmqWaterMark]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqCommon] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqCommon] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerSiftingAppender] to Logger[RocketmqCommon]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqRocksDB] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqRocksDB] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqRocksDBSiftingAppender] to Logger[RocketmqRocksDB]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqStore] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqStore] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqStoreSiftingAppender] to Logger[RocketmqStore]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqStoreError] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqStoreError] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqStoreErrorSiftingAppender] to Logger[RocketmqStoreError]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqTieredStore] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqTieredStore] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqTieredStoreSiftingAppender] to Logger[RocketmqTieredStore]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqTransaction] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqTransaction] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqTransactionSiftingAppender] to Logger[RocketmqTransaction]
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqRebalanceLock] to INFO
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqRebalanceLock] to false
20:24:43,666 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqRebalanceLockSiftingAppender] to Logger[RocketmqRebalanceLock]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqRemoting] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqRemoting] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqRemotingSiftingAppender] to Logger[RocketmqRemoting]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqStats] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqStats] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqStatsSiftingAppender] to Logger[RocketmqStats]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqCommercial] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqCommercial] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqCommercialSiftingAppender] to Logger[RocketmqCommercial]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqConsole] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqConsole] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [STDOUT] to Logger[RocketmqConsole]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqPop] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqPop] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqPopSiftingAppender] to Logger[RocketmqPop]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqColdCtr] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LevelModelHandler - RocketmqColdCtr level set to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqColdCtrSiftingAppender] to Logger[RocketmqColdCtr]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqTraffic] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqTraffic] to false
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqTrafficSiftingAppender] to Logger[RocketmqTraffic]
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingMetricExporter] to INFO
20:24:43,667 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingMetricExporter] to false
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender] to Logger[io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingMetricExporter]
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [io.opentelemetry.exporter.logging.LoggingMetricExporter] to INFO
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [io.opentelemetry.exporter.logging.LoggingMetricExporter] to false
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender] to Logger[io.opentelemetry.exporter.logging.LoggingMetricExporter]
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [RocketmqAuthAudit] to INFO
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [RocketmqAuthAudit] to false
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqAuthAuditSiftingAppender] to Logger[RocketmqAuthAudit]
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.RootLoggerModelHandler - Setting level of ROOT logger to INFO
20:24:43,668 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [DefaultSiftingAppender] to Logger[ROOT]
20:24:43,669 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.DefaultProcessor@159f197 - End of configuration.
20:24:43,672 |-INFO in org.apache.rocketmq.common.logging.JoranConfiguratorExt@78aab498 - Registering current configuration as safe fallback point
The broker[broker-a, 192.168.56.1:10911] boot success. serializeType=JSON and name server is localhost:9876
4.6.3. Broker日志
日志位置：
C:\Users\<用户名>\logs\rocketmqlogs\broker.log
2025-08-10 13:58:49 INFO main - brokerConfigPath=
2025-08-10 13:58:49 INFO main - rocketmqHome=D:\rocketmq\rocketmq-all-5.3.3-bin-release
2025-08-10 13:58:49 INFO main - namesrvAddr=localhost:9876
2025-08-10 13:58:49 INFO main - listenPort=6888
2025-08-10 13:58:49 INFO main - brokerIP1=192.168.56.1
2025-08-10 13:58:49 INFO main - brokerIP2=192.168.56.1
2025-08-10 13:58:49 INFO main - recoverConcurrently=false
2025-08-10 13:58:49 INFO main - brokerPermission=6
2025-08-10 13:58:49 INFO main - defaultTopicQueueNums=8
2025-08-10 13:58:49 INFO main - autoCreateTopicEnable=true
2025-08-10 13:58:49 INFO main - clusterTopicEnable=true
2025-08-10 13:58:49 INFO main - brokerTopicEnable=true
2025-08-10 13:58:49 INFO main - autoCreateSubscriptionGroup=true
2025-08-10 13:58:49 INFO main - messageStorePlugIn=
2025-08-10 13:58:49 INFO main - msgTraceTopicName=RMQ_SYS_TRACE_TOPIC
2025-08-10 13:58:49 INFO main - traceTopicEnable=false
2025-08-10 13:58:49 INFO main - sendMessageThreadPoolNums=4
2025-08-10 13:58:49 INFO main - putMessageFutureThreadPoolNums=4
2025-08-10 13:58:49 INFO main - pullMessageThreadPoolNums=32
2025-08-10 13:58:49 INFO main - litePullMessageThreadPoolNums=32
2025-08-10 13:58:49 INFO main - ackMessageThreadPoolNums=16
2025-08-10 13:58:49 INFO main - processReplyMessageThreadPoolNums=32
2025-08-10 13:58:49 INFO main - queryMessageThreadPoolNums=16
2025-08-10 13:58:49 INFO main - adminBrokerThreadPoolNums=16
2025-08-10 13:58:49 INFO main - clientManageThreadPoolNums=32
2025-08-10 13:58:49 INFO main - consumerManageThreadPoolNums=32
2025-08-10 13:58:49 INFO main - loadBalanceProcessorThreadPoolNums=32
2025-08-10 13:58:49 INFO main - heartbeatThreadPoolNums=8
2025-08-10 13:58:49 INFO main - recoverThreadPoolNums=32
2025-08-10 13:58:49 INFO main - endTransactionThreadPoolNums=24
2025-08-10 13:58:49 INFO main - flushConsumerOffsetInterval=5000
2025-08-10 13:58:49 INFO main - flushConsumerOffsetHistoryInterval=60000
2025-08-10 13:58:49 INFO main - rejectTransactionMessage=false
2025-08-10 13:58:49 INFO main - fetchNameSrvAddrByDnsLookup=false
2025-08-10 13:58:49 INFO main - fetchNamesrvAddrByAddressServer=false
2025-08-10 13:58:49 INFO main - sendThreadPoolQueueCapacity=10000
2025-08-10 13:58:49 INFO main - putThreadPoolQueueCapacity=10000
2025-08-10 13:58:49 INFO main - pullThreadPoolQueueCapacity=100000
2025-08-10 13:58:49 INFO main - litePullThreadPoolQueueCapacity=100000
2025-08-10 13:58:49 INFO main - ackThreadPoolQueueCapacity=100000
2025-08-10 13:58:49 INFO main - replyThreadPoolQueueCapacity=10000
2025-08-10 13:58:49 INFO main - queryThreadPoolQueueCapacity=20000
2025-08-10 13:58:49 INFO main - clientManagerThreadPoolQueueCapacity=1000000
2025-08-10 13:58:49 INFO main - consumerManagerThreadPoolQueueCapacity=1000000
2025-08-10 13:58:49 INFO main - heartbeatThreadPoolQueueCapacity=50000
2025-08-10 13:58:49 INFO main - endTransactionPoolQueueCapacity=100000
2025-08-10 13:58:49 INFO main - adminBrokerThreadPoolQueueCapacity=10000
2025-08-10 13:58:49 INFO main - loadBalanceThreadPoolQueueCapacity=100000
2025-08-10 13:58:49 INFO main - longPollingEnable=true
2025-08-10 13:58:49 INFO main - shortPollingTimeMills=1000
2025-08-10 13:58:49 INFO main - notifyConsumerIdsChangedEnable=true
2025-08-10 13:58:49 INFO main - highSpeedMode=false
2025-08-10 13:58:49 INFO main - commercialBaseCount=1
2025-08-10 13:58:49 INFO main - commercialSizePerMsg=4096
2025-08-10 13:58:49 INFO main - accountStatsEnable=true
2025-08-10 13:58:49 INFO main - accountStatsPrintZeroValues=true
2025-08-10 13:58:49 INFO main - maxStatsIdleTimeInMinutes=-1
2025-08-10 13:58:49 INFO main - transferMsgByHeap=true
2025-08-10 13:58:49 INFO main - regionId=DefaultRegion
2025-08-10 13:58:49 INFO main - registerBrokerTimeoutMills=24000
2025-08-10 13:58:49 INFO main - sendHeartbeatTimeoutMillis=1000
2025-08-10 13:58:49 INFO main - slaveReadEnable=false
2025-08-10 13:58:49 INFO main - disableConsumeIfConsumerReadSlowly=false
2025-08-10 13:58:49 INFO main - consumerFallbehindThreshold=17179869184
2025-08-10 13:58:49 INFO main - brokerFastFailureEnable=true
2025-08-10 13:58:49 INFO main - waitTimeMillsInSendQueue=200
2025-08-10 13:58:49 INFO main - waitTimeMillsInPullQueue=5000
2025-08-10 13:58:49 INFO main - waitTimeMillsInLitePullQueue=5000
2025-08-10 13:58:49 INFO main - waitTimeMillsInHeartbeatQueue=31000
2025-08-10 13:58:49 INFO main - waitTimeMillsInTransactionQueue=3000
2025-08-10 13:58:49 INFO main - waitTimeMillsInAckQueue=3000
2025-08-10 13:58:49 INFO main - waitTimeMillsInAdminBrokerQueue=5000
2025-08-10 13:58:49 INFO main - startAcceptSendRequestTimeStamp=0
2025-08-10 13:58:49 INFO main - traceOn=true
2025-08-10 13:58:49 INFO main - enableCalcFilterBitMap=false
2025-08-10 13:58:49 INFO main - rejectPullConsumerEnable=false
2025-08-10 13:58:49 INFO main - expectConsumerNumUseFilter=32
2025-08-10 13:58:49 INFO main - maxErrorRateOfBloomFilter=20
2025-08-10 13:58:49 INFO main - filterDataCleanTimeSpan=86400000
2025-08-10 13:58:49 INFO main - filterSupportRetry=false
2025-08-10 13:58:49 INFO main - enablePropertyFilter=false
2025-08-10 13:58:49 INFO main - compressedRegister=false
2025-08-10 13:58:49 INFO main - forceRegister=true
2025-08-10 13:58:49 INFO main - registerNameServerPeriod=30000
2025-08-10 13:58:49 INFO main - updateNameServerAddrPeriod=120000
2025-08-10 13:58:49 INFO main - brokerHeartbeatInterval=1000
2025-08-10 13:58:49 INFO main - brokerNotActiveTimeoutMillis=10000
2025-08-10 13:58:49 INFO main - enableNetWorkFlowControl=false
2025-08-10 13:58:49 INFO main - enableBroadcastOffsetStore=true
2025-08-10 13:58:49 INFO main - broadcastOffsetExpireSecond=120
2025-08-10 13:58:49 INFO main - broadcastOffsetExpireMaxSecond=300
2025-08-10 13:58:49 INFO main - popPollingSize=1024
2025-08-10 13:58:49 INFO main - popPollingMapSize=100000
2025-08-10 13:58:49 INFO main - maxPopPollingSize=100000
2025-08-10 13:58:49 INFO main - reviveQueueNum=8
2025-08-10 13:58:49 INFO main - reviveInterval=1000
2025-08-10 13:58:49 INFO main - reviveMaxSlow=3
2025-08-10 13:58:49 INFO main - reviveScanTime=10000
2025-08-10 13:58:49 INFO main - enableSkipLongAwaitingAck=false
2025-08-10 13:58:49 INFO main - reviveAckWaitMs=180000
2025-08-10 13:58:49 INFO main - enablePopLog=false
2025-08-10 13:58:49 INFO main - enablePopBufferMerge=false
2025-08-10 13:58:49 INFO main - popCkStayBufferTime=10000
2025-08-10 13:58:49 INFO main - popCkStayBufferTimeOut=3000
2025-08-10 13:58:49 INFO main - popCkMaxBufferSize=200000
2025-08-10 13:58:49 INFO main - popCkOffsetMaxQueueSize=20000
2025-08-10 13:58:49 INFO main - enablePopBatchAck=false
2025-08-10 13:58:49 INFO main - popLongPollingForceNotifyInterval=800
2025-08-10 13:58:49 INFO main - enableNotifyBeforePopCalculateLag=true
2025-08-10 13:58:49 INFO main - enableNotifyAfterPopOrderLockRelease=true
2025-08-10 13:58:49 INFO main - initPopOffsetByCheckMsgInMem=true
2025-08-10 13:58:49 INFO main - retrieveMessageFromPopRetryTopicV1=true
2025-08-10 13:58:49 INFO main - enableRetryTopicV2=false
2025-08-10 13:58:49 INFO main - popFromRetryProbability=20
2025-08-10 13:58:49 INFO main - popConsumerFSServiceInit=true
2025-08-10 13:58:49 INFO main - popConsumerKVServiceLog=false
2025-08-10 13:58:49 INFO main - popConsumerKVServiceInit=false
2025-08-10 13:58:49 INFO main - popConsumerKVServiceEnable=false
2025-08-10 13:58:49 INFO main - popReviveMaxReturnSizePerRead=16384
2025-08-10 13:58:49 INFO main - popReviveMaxAttemptTimes=16
2025-08-10 13:58:49 INFO main - realTimeNotifyConsumerChange=true
2025-08-10 13:58:49 INFO main - litePullMessageEnable=true
2025-08-10 13:58:49 INFO main - syncBrokerMemberGroupPeriod=1000
2025-08-10 13:58:49 INFO main - loadBalancePollNameServerInterval=30000
2025-08-10 13:58:49 INFO main - cleanOfflineBrokerInterval=30000
2025-08-10 13:58:49 INFO main - serverLoadBalancerEnable=true
2025-08-10 13:58:49 INFO main - defaultMessageRequestMode=PULL
2025-08-10 13:58:49 INFO main - defaultPopShareQueueNum=-1
2025-08-10 13:58:49 INFO main - transactionTimeOut=6000
2025-08-10 13:58:49 INFO main - transactionCheckMax=15
2025-08-10 13:58:49 INFO main - transactionCheckInterval=30000
2025-08-10 13:58:49 INFO main - transactionMetricFlushInterval=3000
2025-08-10 13:58:49 INFO main - transactionOpMsgMaxSize=4096
2025-08-10 13:58:49 INFO main - transactionOpBatchInterval=3000
2025-08-10 13:58:49 INFO main - aclEnable=false
2025-08-10 13:58:49 INFO main - storeReplyMessageEnable=true
2025-08-10 13:58:49 INFO main - enableDetailStat=true
2025-08-10 13:58:49 INFO main - autoDeleteUnusedStats=true
2025-08-10 13:58:49 INFO main - isolateLogEnable=false
2025-08-10 13:58:49 INFO main - forwardTimeout=3000
2025-08-10 13:58:49 INFO main - enableSlaveActingMaster=false
2025-08-10 13:58:49 INFO main - enableRemoteEscape=false
2025-08-10 13:58:49 INFO main - skipPreOnline=false
2025-08-10 13:58:49 INFO main - asyncSendEnable=true
2025-08-10 13:58:49 INFO main - useServerSideResetOffset=true
2025-08-10 13:58:49 INFO main - consumerOffsetUpdateVersionStep=500
2025-08-10 13:58:49 INFO main - delayOffsetUpdateVersionStep=200
2025-08-10 13:58:49 INFO main - lockInStrictMode=false
2025-08-10 13:58:49 INFO main - compatibleWithOldNameSrv=true
2025-08-10 13:58:49 INFO main - enableControllerMode=false
2025-08-10 13:58:49 INFO main - controllerAddr=
2025-08-10 13:58:49 INFO main - fetchControllerAddrByDnsLookup=false
2025-08-10 13:58:49 INFO main - syncBrokerMetadataPeriod=5000
2025-08-10 13:58:49 INFO main - checkSyncStateSetPeriod=5000
2025-08-10 13:58:49 INFO main - syncControllerMetadataPeriod=10000
2025-08-10 13:58:49 INFO main - controllerHeartBeatTimeoutMills=10000
2025-08-10 13:58:49 INFO main - validateSystemTopicWhenUpdateTopic=true
2025-08-10 13:58:49 INFO main - brokerElectionPriority=2147483647
2025-08-10 13:58:49 INFO main - useStaticSubscription=false
2025-08-10 13:58:49 INFO main - metricsExporterType=DISABLE
2025-08-10 13:58:49 INFO main - metricsOtelCardinalityLimit=50000
2025-08-10 13:58:49 INFO main - metricsGrpcExporterTarget=
2025-08-10 13:58:49 INFO main - metricsGrpcExporterHeader=
2025-08-10 13:58:49 INFO main - metricGrpcExporterTimeOutInMills=3000
2025-08-10 13:58:49 INFO main - metricGrpcExporterIntervalInMills=60000
2025-08-10 13:58:49 INFO main - metricLoggingExporterIntervalInMills=10000
2025-08-10 13:58:49 INFO main - metricsPromExporterPort=5557
2025-08-10 13:58:49 INFO main - metricsPromExporterHost=
2025-08-10 13:58:49 INFO main - metricsLabel=
2025-08-10 13:58:49 INFO main - metricsInDelta=false
2025-08-10 13:58:49 INFO main - channelExpiredTimeout=120000
2025-08-10 13:58:49 INFO main - subscriptionExpiredTimeout=600000
2025-08-10 13:58:49 INFO main - estimateAccumulation=true
2025-08-10 13:58:49 INFO main - coldCtrStrategyEnable=false
2025-08-10 13:58:49 INFO main - usePIDColdCtrStrategy=true
2025-08-10 13:58:49 INFO main - cgColdReadThreshold=3145728
2025-08-10 13:58:49 INFO main - globalColdReadThreshold=104857600
2025-08-10 13:58:49 INFO main - fetchNamesrvAddrInterval=10000
2025-08-10 13:58:49 INFO main - popResponseReturnActualRetryTopic=false
2025-08-10 13:58:49 INFO main - enableSingleTopicRegister=false
2025-08-10 13:58:49 INFO main - enableMixedMessageType=false
2025-08-10 13:58:49 INFO main - enableSplitRegistration=false
2025-08-10 13:58:49 INFO main - popInflightMessageThreshold=10000
2025-08-10 13:58:49 INFO main - enablePopMessageThreshold=false
2025-08-10 13:58:49 INFO main - enableFastChannelEventProcess=false
2025-08-10 13:58:49 INFO main - printChannelGroups=false
2025-08-10 13:58:49 INFO main - printChannelGroupsMinNum=5
2025-08-10 13:58:49 INFO main - splitRegistrationSize=800
2025-08-10 13:58:49 INFO main - configBlackList=configBlackList;brokerConfigPath
2025-08-10 13:58:49 INFO main - skipWhenCKRePutReachMaxTimes=false
2025-08-10 13:58:49 INFO main - appendAckAsync=false
2025-08-10 13:58:49 INFO main - appendCkAsync=false
2025-08-10 13:58:49 INFO main - clearRetryTopicWhenDeleteTopic=true
2025-08-10 13:58:49 INFO main - enableLmqStats=false
2025-08-10 13:58:49 INFO main - configManagerVersion=v1
2025-08-10 13:58:49 INFO main - allowRecallWhenBrokerNotWriteable=true
2025-08-10 13:58:49 INFO main - recallMessageEnable=false
2025-08-10 13:58:49 INFO main - enableRegisterProducer=true
2025-08-10 13:58:49 INFO main - enableCreateSysGroup=true
2025-08-10 13:58:49 INFO main - bindAddress=0.0.0.0
2025-08-10 13:58:49 INFO main - listenPort=10911
2025-08-10 13:58:49 INFO main - serverWorkerThreads=8
2025-08-10 13:58:49 INFO main - serverCallbackExecutorThreads=0
2025-08-10 13:58:49 INFO main - serverSelectorThreads=3
2025-08-10 13:58:49 INFO main - serverOnewaySemaphoreValue=256
2025-08-10 13:58:49 INFO main - serverAsyncSemaphoreValue=64
2025-08-10 13:58:49 INFO main - serverChannelMaxIdleTimeSeconds=120
2025-08-10 13:58:49 INFO main - compactionThreadNum=6
2025-08-10 13:58:49 INFO main - enableCompaction=true
2025-08-10 13:58:49 INFO main - mappedFileSizeTimerLog=104857600
2025-08-10 13:58:49 INFO main - timerPrecisionMs=1000
2025-08-10 13:58:49 INFO main - timerRollWindowSlot=172800
2025-08-10 13:58:49 INFO main - timerFlushIntervalMs=1000
2025-08-10 13:58:49 INFO main - timerGetMessageThreadNum=3
2025-08-10 13:58:49 INFO main - timerPutMessageThreadNum=3
2025-08-10 13:58:49 INFO main - timerEnableDisruptor=false
2025-08-10 13:58:49 INFO main - timerEnableCheckMetrics=true
2025-08-10 13:58:49 INFO main - timerInterceptDelayLevel=false
2025-08-10 13:58:49 INFO main - timerMaxDelaySec=259200
2025-08-10 13:58:49 INFO main - timerWheelEnable=true
2025-08-10 13:58:49 INFO main - disappearTimeAfterStart=-1
2025-08-10 13:58:49 INFO main - timerStopEnqueue=false
2025-08-10 13:58:49 INFO main - timerCheckMetricsWhen=05
2025-08-10 13:58:49 INFO main - timerSkipUnknownError=false
2025-08-10 13:58:49 INFO main - timerWarmEnable=false
2025-08-10 13:58:49 INFO main - timerStopDequeue=false
2025-08-10 13:58:49 INFO main - timerEnableRetryUntilSuccess=false
2025-08-10 13:58:49 INFO main - timerCongestNumEachSlot=2147483647
2025-08-10 13:58:49 INFO main - timerMetricSmallThreshold=1000000
2025-08-10 13:58:49 INFO main - timerProgressLogIntervalMs=10000
2025-08-10 13:58:49 INFO main - storeType=default
2025-08-10 13:58:49 INFO main - mappedFileSizeConsumeQueue=6000000
2025-08-10 13:58:49 INFO main - enableConsumeQueueExt=false
2025-08-10 13:58:49 INFO main - mappedFileSizeConsumeQueueExt=50331648
2025-08-10 13:58:49 INFO main - mapperFileSizeBatchConsumeQueue=13800000
2025-08-10 13:58:49 INFO main - bitMapLengthConsumeQueueExt=64
2025-08-10 13:58:49 INFO main - flushIntervalCommitLog=500
2025-08-10 13:58:49 INFO main - commitIntervalCommitLog=200
2025-08-10 13:58:49 INFO main - maxRecoveryCommitlogFiles=30
2025-08-10 13:58:49 INFO main - diskSpaceWarningLevelRatio=90
2025-08-10 13:58:49 INFO main - diskSpaceCleanForciblyRatio=85
2025-08-10 13:58:49 INFO main - useReentrantLockWhenPutMessage=true
2025-08-10 13:58:49 INFO main - flushCommitLogTimed=true
2025-08-10 13:58:49 INFO main - flushIntervalConsumeQueue=1000
2025-08-10 13:58:49 INFO main - cleanResourceInterval=10000
2025-08-10 13:58:49 INFO main - deleteCommitLogFilesInterval=100
2025-08-10 13:58:49 INFO main - deleteConsumeQueueFilesInterval=100
2025-08-10 13:58:49 INFO main - destroyMapedFileIntervalForcibly=120000
2025-08-10 13:58:49 INFO main - redeleteHangedFileInterval=120000
2025-08-10 13:58:49 INFO main - deleteWhen=04
2025-08-10 13:58:49 INFO main - diskMaxUsedSpaceRatio=75
2025-08-10 13:58:49 INFO main - fileReservedTime=72
2025-08-10 13:58:49 INFO main - deleteFileBatchMax=10
2025-08-10 13:58:49 INFO main - putMsgIndexHightWater=600000
2025-08-10 13:58:49 INFO main - maxMessageSize=4194304
2025-08-10 13:58:49 INFO main - maxFilterMessageSize=16000
2025-08-10 13:58:49 INFO main - checkCRCOnRecover=true
2025-08-10 13:58:49 INFO main - flushCommitLogLeastPages=4
2025-08-10 13:58:49 INFO main - commitCommitLogLeastPages=4
2025-08-10 13:58:49 INFO main - flushLeastPagesWhenWarmMapedFile=4096
2025-08-10 13:58:49 INFO main - flushConsumeQueueLeastPages=2
2025-08-10 13:58:49 INFO main - flushCommitLogThoroughInterval=10000
2025-08-10 13:58:49 INFO main - commitCommitLogThoroughInterval=200
2025-08-10 13:58:49 INFO main - flushConsumeQueueThoroughInterval=60000
2025-08-10 13:58:49 INFO main - maxTransferBytesOnMessageInMemory=262144
2025-08-10 13:58:49 INFO main - maxTransferCountOnMessageInMemory=32
2025-08-10 13:58:49 INFO main - maxTransferBytesOnMessageInDisk=65536
2025-08-10 13:58:49 INFO main - maxTransferCountOnMessageInDisk=8
2025-08-10 13:58:49 INFO main - accessMessageInMemoryMaxRatio=40
2025-08-10 13:58:49 INFO main - messageIndexEnable=true
2025-08-10 13:58:49 INFO main - maxHashSlotNum=5000000
2025-08-10 13:58:49 INFO main - maxIndexNum=20000000
2025-08-10 13:58:49 INFO main - maxMsgsNumBatch=64
2025-08-10 13:58:49 INFO main - messageIndexSafe=false
2025-08-10 13:58:49 INFO main - haListenPort=10912
2025-08-10 13:58:49 INFO main - haSendHeartbeatInterval=5000
2025-08-10 13:58:49 INFO main - haHousekeepingInterval=20000
2025-08-10 13:58:49 INFO main - haTransferBatchSize=32768
2025-08-10 13:58:49 INFO main - haMasterAddress=
2025-08-10 13:58:49 INFO main - haMaxGapNotInSync=268435456
2025-08-10 13:58:49 INFO main - brokerRole=ASYNC_MASTER
2025-08-10 13:58:49 INFO main - flushDiskType=ASYNC_FLUSH
2025-08-10 13:58:49 INFO main - syncFlushTimeout=5000
2025-08-10 13:58:49 INFO main - putMessageTimeout=8000
2025-08-10 13:58:49 INFO main - slaveTimeout=3000
2025-08-10 13:58:49 INFO main - messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
2025-08-10 13:58:49 INFO main - flushDelayOffsetInterval=10000
2025-08-10 13:58:49 INFO main - cleanFileForciblyEnable=true
2025-08-10 13:58:49 INFO main - warmMapedFileEnable=false
2025-08-10 13:58:49 INFO main - offsetCheckInSlave=false
2025-08-10 13:58:49 INFO main - debugLockEnable=false
2025-08-10 13:58:49 INFO main - duplicationEnable=false
2025-08-10 13:58:49 INFO main - diskFallRecorded=true
2025-08-10 13:58:49 INFO main - osPageCacheBusyTimeOutMills=1000
2025-08-10 13:58:49 INFO main - defaultQueryMaxNum=32
2025-08-10 13:58:49 INFO main - transientStorePoolEnable=false
2025-08-10 13:58:49 INFO main - transientStorePoolSize=5
2025-08-10 13:58:49 INFO main - fastFailIfNoBufferInStorePool=false
2025-08-10 13:58:49 INFO main - enableDLegerCommitLog=false
2025-08-10 13:58:49 INFO main - dLegerGroup=
2025-08-10 13:58:49 INFO main - dLegerPeers=
2025-08-10 13:58:49 INFO main - dLegerSelfId=
2025-08-10 13:58:49 INFO main - preferredLeaderId=
2025-08-10 13:58:49 INFO main - enableBatchPush=false
2025-08-10 13:58:49 INFO main - enableScheduleMessageStats=true
2025-08-10 13:58:49 INFO main - enableLmq=false
2025-08-10 13:58:49 INFO main - enableMultiDispatch=false
2025-08-10 13:58:49 INFO main - maxLmqConsumeQueueNum=20000
2025-08-10 13:58:49 INFO main - enableScheduleAsyncDeliver=false
2025-08-10 13:58:49 INFO main - scheduleAsyncDeliverMaxPendingLimit=2000
2025-08-10 13:58:49 INFO main - scheduleAsyncDeliverMaxResendNum2Blocked=3
2025-08-10 13:58:49 INFO main - maxBatchDeleteFilesNum=50
2025-08-10 13:58:49 INFO main - dispatchCqThreads=10
2025-08-10 13:58:49 INFO main - dispatchCqCacheNum=4096
2025-08-10 13:58:49 INFO main - enableAsyncReput=true
2025-08-10 13:58:49 INFO main - recheckReputOffsetFromCq=false
2025-08-10 13:58:49 INFO main - maxTopicLength=127
2025-08-10 13:58:49 INFO main - autoMessageVersionOnTopicLen=true
2025-08-10 13:58:49 INFO main - enabledAppendPropCRC=false
2025-08-10 13:58:49 INFO main - forceVerifyPropCRC=false
2025-08-10 13:58:49 INFO main - travelCqFileNumWhenGetMessage=1
2025-08-10 13:58:49 INFO main - correctLogicMinOffsetSleepInterval=1
2025-08-10 13:58:49 INFO main - correctLogicMinOffsetForceInterval=300000
2025-08-10 13:58:49 INFO main - mappedFileSwapEnable=true
2025-08-10 13:58:49 INFO main - commitLogForceSwapMapInterval=43200000
2025-08-10 13:58:49 INFO main - commitLogSwapMapInterval=3600000
2025-08-10 13:58:49 INFO main - commitLogSwapMapReserveFileNum=100
2025-08-10 13:58:49 INFO main - logicQueueForceSwapMapInterval=43200000
2025-08-10 13:58:49 INFO main - logicQueueSwapMapInterval=3600000
2025-08-10 13:58:49 INFO main - cleanSwapedMapInterval=300000
2025-08-10 13:58:49 INFO main - logicQueueSwapMapReserveFileNum=20
2025-08-10 13:58:49 INFO main - searchBcqByCacheEnable=true
2025-08-10 13:58:49 INFO main - dispatchFromSenderThread=false
2025-08-10 13:58:49 INFO main - wakeCommitWhenPutMessage=true
2025-08-10 13:58:49 INFO main - wakeFlushWhenPutMessage=false
2025-08-10 13:58:49 INFO main - enableCleanExpiredOffset=false
2025-08-10 13:58:49 INFO main - maxAsyncPutMessageRequests=5000
2025-08-10 13:58:49 INFO main - pullBatchMaxMessageCount=160
2025-08-10 13:58:49 INFO main - totalReplicas=1
2025-08-10 13:58:49 INFO main - inSyncReplicas=1
2025-08-10 13:58:49 INFO main - minInSyncReplicas=1
2025-08-10 13:58:49 INFO main - allAckInSyncStateSet=false
2025-08-10 13:58:49 INFO main - enableAutoInSyncReplicas=false
2025-08-10 13:58:49 INFO main - haFlowControlEnable=false
2025-08-10 13:58:49 INFO main - maxHaTransferByteInSecond=104857600
2025-08-10 13:58:49 INFO main - haMaxTimeSlaveNotCatchup=15000
2025-08-10 13:58:49 INFO main - syncMasterFlushOffsetWhenStartup=false
2025-08-10 13:58:49 INFO main - maxChecksumRange=1073741824
2025-08-10 13:58:49 INFO main - replicasPerDiskPartition=1
2025-08-10 13:58:49 INFO main - logicalDiskSpaceCleanForciblyThreshold=0.8
2025-08-10 13:58:49 INFO main - maxSlaveResendLength=268435456
2025-08-10 13:58:49 INFO main - syncFromLastFile=false
2025-08-10 13:58:49 INFO main - asyncLearner=false
2025-08-10 13:58:49 INFO main - maxConsumeQueueScan=20000
2025-08-10 13:58:49 INFO main - sampleCountThreshold=5000
2025-08-10 13:58:49 INFO main - coldDataFlowControlEnable=false
2025-08-10 13:58:49 INFO main - coldDataScanEnable=false
2025-08-10 13:58:49 INFO main - dataReadAheadEnable=true
2025-08-10 13:58:49 INFO main - timerColdDataCheckIntervalMs=60000
2025-08-10 13:58:49 INFO main - sampleSteps=32
2025-08-10 13:58:49 INFO main - accessMessageInMemoryHotRatio=26
2025-08-10 13:58:49 INFO main - enableBuildConsumeQueueConcurrently=false
2025-08-10 13:58:49 INFO main - batchDispatchRequestThreadPoolNums=16
2025-08-10 13:58:49 INFO main - cleanRocksDBDirtyCQIntervalMin=60
2025-08-10 13:58:49 INFO main - statRocksDBCQIntervalSec=10
2025-08-10 13:58:49 INFO main - memTableFlushIntervalMs=3600000
2025-08-10 13:58:49 INFO main - realTimePersistRocksDBConfig=true
2025-08-10 13:58:49 INFO main - enableRocksDBLog=false
2025-08-10 13:58:49 INFO main - topicQueueLockNum=32
2025-08-10 13:58:49 INFO main - readUnCommitted=false
2025-08-10 13:58:49 INFO main - putConsumeQueueDataByFileChannel=true
2025-08-10 13:58:49 INFO main - rocksdbCQDoubleWriteEnable=false
2025-08-10 13:58:49 INFO main - bottomMostCompressionTypeForConsumeQueueStore=zstd
2025-08-10 13:58:49 INFO main - rocksdbCompressionType=lz4
2025-08-10 13:58:49 INFO main - rocksdbFlushWalFrequency=1024
2025-08-10 13:58:49 INFO main - rocksdbWalFileRollingThreshold=1073741824
2025-08-10 13:58:49 INFO main - spinLockCollisionRetreatOptimalDegree=1000
2025-08-10 13:58:49 INFO main - useABSLock=false
2025-08-10 13:58:51 INFO main - Replace, key: listenPort, value: 6888 -> 10911
2025-08-10 13:58:51 INFO main - load C:\Users\<用户名>\store\config\consumerOffset.json OK
2025-08-10 13:58:51 INFO main - load C:\Users\<用户名>\store\config\consumerFilter.json OK
2025-08-10 13:58:51 INFO main - load C:\Users\<用户名>\store\config\consumerOrderInfo.json OK
2025-08-10 13:58:51 INFO main - Looking for a resource file of name [META-INF/service/org.apache.rocketmq.store.ha.HAService] ...
2025-08-10 13:58:51 WARN main - No resource file with name [META-INF/service/org.apache.rocketmq.store.ha.HAService] found.
2025-08-10 13:58:51 INFO main - load C:\Users\<用户名>\store\config\timermetrics OK
2025-08-10 13:58:51 INFO main - load C:\Users\<用户名>\store\config\delayOffset.json OK
2025-08-10 13:58:56 INFO main - Set user specified name server address: localhost:9876
2025-08-10 13:58:56 INFO main - Looking for a resource file of name [META-INF/service/org.apache.rocketmq.broker.transaction.TransactionalMessageService] ...
2025-08-10 13:58:56 WARN main - No resource file with name [META-INF/service/org.apache.rocketmq.broker.transaction.TransactionalMessageService] found.
2025-08-10 13:58:56 INFO main - Try to start service thread:TransactionalOpBatchService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:TransactionalOpBatchService started:true lastThread:Thread[#60,TransactionalOpBatchService,5,main]
2025-08-10 13:58:56 INFO main - load C:\Users\<用户名>\store\config\transactionMetrics OK
2025-08-10 13:58:56 WARN main - Load default transaction message hook service: TransactionalMessageServiceImpl
2025-08-10 13:58:56 INFO main - Looking for a resource file of name [META-INF/service/org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener] ...
2025-08-10 13:58:56 WARN main - No resource file with name [META-INF/service/org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener] found.
2025-08-10 13:58:56 WARN main - Load default discard message hook service: DefaultTransactionalMessageCheckListener
2025-08-10 13:58:56 INFO main - Try to start service thread:TransactionFlushService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:TransactionFlushService started:true lastThread:Thread[#61,TransactionFlushService,5,main]
2025-08-10 13:58:56 INFO main - Looking for a resource file of name [META-INF/service/org.apache.rocketmq.remoting.RPCHook] ...
2025-08-10 13:58:56 WARN main - No resource file with name [META-INF/service/org.apache.rocketmq.remoting.RPCHook] found.
2025-08-10 13:58:56 INFO main - Try to start service thread:NettyEventExecutor started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:NettyEventExecutor started:true lastThread:Thread[#63,NettyEventExecutor,5,main]
2025-08-10 13:58:56 INFO NettyEventExecutor - NettyEventExecutor service started
2025-08-10 13:58:56 INFO main - Try to start service thread:AllocateMappedFileService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:AllocateMappedFileService started:true lastThread:Thread[#64,AllocateMappedFileService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:ReputMessageService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:ReputMessageService started:true lastThread:Thread[#65,ReputMessageService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:FlushConsumeQueueService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:FlushConsumeQueueService started:true lastThread:Thread[#66,FlushConsumeQueueService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:FlushRealTimeService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:FlushRealTimeService started:true lastThread:Thread[#67,FlushRealTimeService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:FlushDiskWatcher started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:FlushDiskWatcher started:true lastThread:Thread[#68,FlushDiskWatcher,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:ColdDataCheckService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:ColdDataCheckService started:true lastThread:Thread[#69,ColdDataCheckService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:StoreStatsService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:StoreStatsService started:true lastThread:Thread[#70,StoreStatsService,5,main]
2025-08-10 13:58:56 INFO ColdDataCheckService - ColdDataCheckService service started
2025-08-10 13:58:56 INFO main - Try to start service thread:DefaultAcceptSocketService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:DefaultAcceptSocketService started:true lastThread:Thread[#71,DefaultAcceptSocketService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:GroupTransferService started:false lastThread:null
2025-08-10 13:58:56 INFO main - Start service thread:GroupTransferService started:true lastThread:Thread[#72,GroupTransferService,5,main]
2025-08-10 13:58:56 INFO main - Try to start service thread:HAConnectionStateNotificationService started:false lastThread:null
2025-08-10 13:58:56 INFO DefaultAcceptSocketService - DefaultAcceptSocketService service started
2025-08-10 13:58:56 INFO main - Start service thread:HAConnectionStateNotificationService started:true lastThread:Thread[#73,HAConnectionStateNotificationService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:org.apache.rocketmq.store.util.PerfCounter$Ticks started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:org.apache.rocketmq.store.util.PerfCounter$Ticks started:true lastThread:Thread[#76,org.apache.rocketmq.store.util.PerfCounter$Ticks,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerEnqueueGetService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerEnqueueGetService started:true lastThread:Thread[#77,TimerEnqueueGetService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerEnqueuePutService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerEnqueuePutService started:true lastThread:Thread[#78,TimerEnqueuePutService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeueWarmService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeueWarmService started:true lastThread:Thread[#79,TimerDequeueWarmService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeueGetService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeueGetService started:true lastThread:Thread[#80,TimerDequeueGetService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeueGetMessageService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeueGetMessageService started:true lastThread:Thread[#81,TimerDequeueGetMessageService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeueGetMessageService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeueGetMessageService started:true lastThread:Thread[#82,TimerDequeueGetMessageService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeueGetMessageService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeueGetMessageService started:true lastThread:Thread[#83,TimerDequeueGetMessageService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeuePutMessageService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeuePutMessageService started:true lastThread:Thread[#84,TimerDequeuePutMessageService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeuePutMessageService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeuePutMessageService started:true lastThread:Thread[#85,TimerDequeuePutMessageService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerDequeuePutMessageService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerDequeuePutMessageService started:true lastThread:Thread[#86,TimerDequeuePutMessageService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TimerFlushService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TimerFlushService started:true lastThread:Thread[#87,TimerFlushService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:NettyEventExecutor started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:NettyEventExecutor started:true lastThread:Thread[#92,NettyEventExecutor,5,main]
2025-08-10 13:58:57 INFO NettyEventExecutor - NettyEventExecutor service started
2025-08-10 13:58:57 INFO main - Try to start service thread:NettyEventExecutor started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:NettyEventExecutor started:true lastThread:Thread[#95,NettyEventExecutor,5,main]
2025-08-10 13:58:57 INFO NettyEventExecutor - NettyEventExecutor service started
2025-08-10 13:58:57 INFO main - Try to start service thread:PopLongPollingService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopLongPollingService started:true lastThread:Thread[#97,PopLongPollingService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopBufferMergeService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopBufferMergeService started:true lastThread:Thread[#98,PopBufferMergeService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:QueueLockManager started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:QueueLockManager started:true lastThread:Thread[#99,QueueLockManager,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_0 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_0 started:true lastThread:Thread[#100,PopReviveService_0,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_1 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_1 started:true lastThread:Thread[#101,PopReviveService_1,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_2 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_2 started:true lastThread:Thread[#102,PopReviveService_2,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_3 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_3 started:true lastThread:Thread[#103,PopReviveService_3,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_4 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_4 started:true lastThread:Thread[#105,PopReviveService_4,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_5 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_5 started:true lastThread:Thread[#106,PopReviveService_5,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_6 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_6 started:true lastThread:Thread[#107,PopReviveService_6,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopReviveService_7 started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopReviveService_7 started:true lastThread:Thread[#108,PopReviveService_7,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PopLongPollingService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:PopLongPollingService started:true lastThread:Thread[#109,PopLongPollingService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:TopicQueueMappingCleanService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TopicQueueMappingCleanService started:true lastThread:Thread[#110,TopicQueueMappingCleanService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:FileWatchService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:FileWatchService started:true lastThread:Thread[#111,FileWatchService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:PullRequestHoldService started:false lastThread:null
2025-08-10 13:58:57 INFO TopicQueueMappingCleanService - Start topic queue mapping clean service thread!
2025-08-10 13:58:57 INFO main - Start service thread:PullRequestHoldService started:true lastThread:Thread[#112,PullRequestHoldService,5,main]
2025-08-10 13:58:57 INFO FileWatchService - FileWatchService service started
2025-08-10 13:58:57 INFO PullRequestHoldService - PullRequestHoldService service started
2025-08-10 13:58:57 INFO main - Try to start service thread:BroadcastOffsetManager started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:BroadcastOffsetManager started:true lastThread:Thread[#115,BroadcastOffsetManager,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:ColdDataPullRequestHoldService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:ColdDataPullRequestHoldService started:true lastThread:Thread[#117,ColdDataPullRequestHoldService,5,main]
2025-08-10 13:58:57 INFO main - Try to start service thread:ColdDataCgCtrService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:ColdDataCgCtrService started:true lastThread:Thread[#118,ColdDataCgCtrService,5,main]
2025-08-10 13:58:57 INFO main - ScheduleServiceStatus changed to true
2025-08-10 13:58:57 INFO main - load C:\Users\<用户名>\store\config\delayOffset.json OK
2025-08-10 13:58:57 INFO main - TransactionCheckService status changed to true
2025-08-10 13:58:57 INFO main - Try to start service thread:TransactionalMessageCheckService started:false lastThread:null
2025-08-10 13:58:57 INFO main - Start service thread:TransactionalMessageCheckService started:true lastThread:Thread[#138,TransactionalMessageCheckService,5,main]
2025-08-10 13:58:57 INFO main - Set PopReviveService Status to true
2025-08-10 13:58:57 INFO main - The broker[my-device-name, 192.168.56.1:10911] boot success. serializeType=JSON and name server is localhost:9876
2025-08-10 13:59:06 INFO BrokerControllerScheduledThread1 - Dispatch task fall behind commit log 0bytes
2025-08-10 13:59:07 INFO brokerOutApi_thread_1 - Registering current broker to name server completed. TargetHost=localhost:9876
2025-08-10 13:59:37 INFO brokerOutApi_thread_2 - Registering current broker to name server completed. TargetHost=localhost:9876
2025-08-10 14:00:06 INFO BrokerControllerScheduledThread1 - Dispatch task fall behind commit log 0bytes
2025-08-10 14:00:07 INFO brokerOutApi_thread_3 - Registering current broker to name server completed. TargetHost=localhost:9876
2025-08-10 14:00:37 INFO brokerOutApi_thread_4 - Registering current broker to name server completed. TargetHost=localhost:9876
2025-08-10 14:01:06 INFO BrokerControllerScheduledThread1 - Dispatch task fall behind commit log 0bytes
2025-08-10 14:01:07 INFO brokerOutApi_thread_1 - Registering current broker to name server completed. TargetHost=localhost:9876
2025-08-10 14:01:37 INFO brokerOutApi_thread_2 - Registering current broker to name server completed. TargetHost=localhost:9876
5. RocketMQ Dashboard
RocketMQ 控制台：Apache RocketMQ 的运维操作界面。
5.1. 下载 RocketMQ Dashboard
下载地址，在官网下载界面：
5.2. 源代码和使用文档（github 地址）
github源代码和使用文档
https://github.com/apache/rocketmq-dashboard/blob/master/docs/1_0_0/UserGuide_CN.md
5.3. 运行 RocketMQ Dashboard
5.3.1. 开发模式运行
rocketmq-dashboard-2.0.0-source-release，解压项目 ，本次测试，直接使用 IDEA 打开项目，并开发模式运行。
5.3.2. 升级 Lombok 至兼容版本
默认POM配置报错：
java: java.lang.NoSuchFieldError: Class com.sun.tools.javac.tree.JCTree$JCImport does not have member field 'com.sun.tools.javac.tree.JCTree qualid'
升级 Lombok 至兼容版本 1.18.30 后，能够正常构建运行。
<!-- 原版本 -->
<!-- <lombok.version>1.18.22</lombok.version>-->
<!-- 升级 Lombok 至兼容版本 -->
<lombok.version>1.18.30</lombok.version>
5.4. 控制台日志
16:15:07,538 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback-test.xml]
16:15:07,539 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback.groovy]
16:15:07,540 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback.xml] at [file:/D:/rocketmq/rocketmq-dashboard-2.0.0-source-release/target/classes/logback.xml]
16:15:07,814 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - debug attribute not set
16:15:07,815 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]
16:15:07,836 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [STDOUT]
16:15:07,858 |-INFO in ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
16:15:08,096 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.rolling.RollingFileAppender]
16:15:08,111 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [FILE]
16:15:08,211 |-INFO in c.q.l.core.rolling.TimeBasedRollingPolicy@558569884 - No compression will be used
16:15:08,214 |-INFO in c.q.l.core.rolling.TimeBasedRollingPolicy@558569884 - Will use the pattern C:/Users/<用户名>/logs/dashboardlogs/rocketmq-dashboard-%d{yyyy-MM-dd}.%i.log for the active file
16:15:08,221 |-INFO in ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP@20d3d15a - The date pattern is 'yyyy-MM-dd' from file name pattern 'C:/Users/<用户名>/logs/dashboardlogs/rocketmq-dashboard-%d{yyyy-MM-dd}.%i.log'.
16:15:08,221 |-INFO in ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP@20d3d15a - Roll-over at midnight.
16:15:08,414 |-INFO in ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP@20d3d15a - Setting initial period to Sun Aug 10 16:14:49 GMT+08:00 2025
16:15:08,416 |-WARN in ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP@20d3d15a - SizeAndTimeBasedFNATP is deprecated. Use SizeAndTimeBasedRollingPolicy instead
16:15:08,416 |-WARN in ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP@20d3d15a - For more information see http://logback.qos.ch/manual/appenders.html#SizeAndTimeBasedRollingPolicy
16:15:08,425 |-INFO in ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
16:15:08,432 |-INFO in ch.qos.logback.core.rolling.RollingFileAppender[FILE] - Active log file name: C:\Users\<用户名>/logs/dashboardlogs/rocketmq-dashboard.log
16:15:08,432 |-INFO in ch.qos.logback.core.rolling.RollingFileAppender[FILE] - File property is set to [C:\Users\<用户名>/logs/dashboardlogs/rocketmq-dashboard.log]
16:15:08,438 |-INFO in ch.qos.logback.classic.joran.action.RootLoggerAction - Setting level of ROOT logger to INFO
16:15:08,438 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [STDOUT] to Logger[ROOT]
16:15:08,440 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [FILE] to Logger[ROOT]
16:15:08,440 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - End of configuration.
16:15:08,445 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@2893de87 - Registering current configuration as safe fallback point
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.6.0)
[2025-08-10 16:15:10.611] INFO background-preinit - HV000001: Hibernate Validator 6.2.0.Final
[2025-08-10 16:15:10.622] INFO main - Starting App using Java 21.0.1 on my-device-name with PID 16176 (D:\rocketmq\rocketmq-dashboard-2.0.0-source-release\target\classes started by <用户名> in D:\rocketmq\rocketmq-dashboard-2.0.0-source-release)
[2025-08-10 16:15:10.623] INFO main - No active profile set, falling back to default profiles: default
[2025-08-10 16:15:16.378] INFO main - setNameSrvAddrByProperty nameSrvAddr=127.0.0.1:9876
[2025-08-10 16:15:17.509] INFO main - Tomcat initialized with port(s): 8080 (http)
[2025-08-10 16:15:17.609] INFO main - Initializing ProtocolHandler ["http-nio-8080"]
[2025-08-10 16:15:17.611] INFO main - Starting service [Tomcat]
[2025-08-10 16:15:17.612] INFO main - Starting Servlet engine: [Apache Tomcat/9.0.55]
[2025-08-10 16:15:18.096] INFO main - Initializing Spring embedded WebApplicationContext
[2025-08-10 16:15:18.096] INFO main - Root WebApplicationContext: initialization completed in 7240 ms
[2025-08-10 16:15:22.721] INFO main - Adding welcome page: class path resource [static/index.html]
[2025-08-10 16:15:24.022] INFO main - Exposing 1 endpoint(s) beneath base path '/actuator'
[2025-08-10 16:15:24.127] INFO main - Starting ProtocolHandler ["http-nio-8080"]
[2025-08-10 16:15:24.286] INFO main - Tomcat started on port(s): 8080 (http) with context path ''
[2025-08-10 16:15:24.369] INFO main - Started App in 15.428 seconds (JVM running for 18.096)
[2025-08-10 16:15:30.760] INFO scheduling-1 - create MQAdmin instance ClientConfig [namesrvAddr=127.0.0.1:9876, clientIP=192.168.56.1, instanceName=1754813730058, clientCallbackExecutorThreads=8, pollNameServerInterval=30000, heartbeatBrokerInterval=30000, persistConsumerOffsetInterval=5000, pullTimeDelayMillsWhenException=1000, unitMode=false, unitName=null, vipChannelEnabled=true, useTLS=false, socksProxyConfig={}, language=JAVA, namespace=null, mqClientApiTimeout=3000, decodeReadBody=true, decodeDecompressBody=true, enableStreamRequestType=false] success.
[2025-08-10 16:15:36.711] INFO http-nio-8080-exec-2 - Initializing Spring DispatcherServlet 'dispatcherServlet'
[2025-08-10 16:15:36.712] INFO http-nio-8080-exec-2 - Initializing Servlet 'dispatcherServlet'
[2025-08-10 16:15:36.715] INFO http-nio-8080-exec-2 - Completed initialization in 3 ms
5.5. 控制台面板
在浏览器中，打开 RocketMQ 的运维操作界面。
更多推荐
29
0- 0
已为社区贡献6条内容
所有评论(0)