本文主要是介绍spring boot连接RocketMQ报错:Send [3] times, still failed, cost [573]ms, Topic: log-message-topic-mingdes,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一开始报了这个错 没有创建这个topic 注意:没有这个报错直接进行第二个步骤
在这个/usr/local/rocketmq-all-5.1.1-bin-release/bin文件夹里输入 命令:
sh mqadmin updateTopic -b localhost:10911 -t log-message-topic-mingdesw -n localhost:9876
这个命令是创建topic名字叫log-message-topic-mingdesw
步骤二:
报错如下:
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14 DESC: service not available now. It may be caused by one of the following reasons: the broker's disk is full [CL: 0.95 CQ: 0.95 INDEX: -1.00], messages are put to the slave, message store has been shut down, etc. BROKER: 192.168.195.66:10911
我这里应该是Broker 的磁盘已满
根据RocketMQ安装目录对runbroker.sh文件进行修改磁盘的大小 (runbroker.sh文件在RocketMQ安装目录下的bin文件夹里;我的文件目/usr/local/rocketmq-all-5.1.1-bin-release/bin
)
进入runbroker.sh后输入:set nu PS:这个命令是显示行数
把103行的 #JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g" 注释掉,这里也可以修改较小的数值 注意:数值可能不一样 比如这样的:JAVA_OPT="S[JAVAOPT} -server -Xms256m -Xmx256m -Xmn128m -Xx:Metaspacesize=128m
-XX:MaxMetaspacesize=320m" 是JAVA_OPT="S[JAVAOPT} -server开头的就可以注释
在文件末尾加入这一行代码
set "JAVA_OPT=%JAVA_OPT% -Drocketmq.broker.diskSpaceWarningLevelRatio=0.98"
输入 :wq 保存并退出
停止命令:
当前目录位置:/usr/local/rocketmq-all-5.1.1-bin-release/bin
sh mqshutdown broker 关闭 broker
sh mqshutdown namesrv 关闭 namesrv
启动命令:
当前目录位置:/usr/local/rocketmq-all-5.1.1-bin-release/bin
nohup sh mqnamesrv & 启动NameServer
nohup sh mqbroker -n localhost:9876 & 启动Broker
通过jps命令查看是否启动
这篇关于spring boot连接RocketMQ报错:Send [3] times, still failed, cost [573]ms, Topic: log-message-topic-mingdes的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!