spring boot连接RocketMQ报错:Send [3] times, still failed, cost [573]ms, Topic: log-message-topic-mingdes

本文主要是介绍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的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/666351

相关文章

Java NoClassDefFoundError运行时错误分析解决

《JavaNoClassDefFoundError运行时错误分析解决》在Java开发中,NoClassDefFoundError是一种常见的运行时错误,它通常表明Java虚拟机在尝试加载一个类时未能... 目录前言一、问题分析二、报错原因三、解决思路检查类路径配置检查依赖库检查类文件调试类加载器问题四、常见

Java注解之超越Javadoc的元数据利器详解

《Java注解之超越Javadoc的元数据利器详解》本文将深入探讨Java注解的定义、类型、内置注解、自定义注解、保留策略、实际应用场景及最佳实践,无论是初学者还是资深开发者,都能通过本文了解如何利用... 目录什么是注解?注解的类型内置注编程解自定义注解注解的保留策略实际用例最佳实践总结在 Java 编程

电脑找不到mfc90u.dll文件怎么办? 系统报错mfc90u.dll丢失修复的5种方案

《电脑找不到mfc90u.dll文件怎么办?系统报错mfc90u.dll丢失修复的5种方案》在我们日常使用电脑的过程中,可能会遇到一些软件或系统错误,其中之一就是mfc90u.dll丢失,那么,mf... 在大部分情况下出现我们运行或安装软件,游戏出现提示丢失某些DLL文件或OCX文件的原因可能是原始安装包

电脑显示mfc100u.dll丢失怎么办?系统报错mfc90u.dll丢失5种修复方案

《电脑显示mfc100u.dll丢失怎么办?系统报错mfc90u.dll丢失5种修复方案》最近有不少兄弟反映,电脑突然弹出“mfc100u.dll已加载,但找不到入口点”的错误提示,导致一些程序无法正... 在计算机使用过程中,我们经常会遇到一些错误提示,其中最常见的就是“找不到指定的模块”或“缺少某个DL

MySQL 多表连接操作方法(INNER JOIN、LEFT JOIN、RIGHT JOIN、FULL OUTER JOIN)

《MySQL多表连接操作方法(INNERJOIN、LEFTJOIN、RIGHTJOIN、FULLOUTERJOIN)》多表连接是一种将两个或多个表中的数据组合在一起的SQL操作,通过连接,... 目录一、 什么是多表连接?二、 mysql 支持的连接类型三、 多表连接的语法四、实战示例 数据准备五、连接的性

解决IDEA报错:编码GBK的不可映射字符问题

《解决IDEA报错:编码GBK的不可映射字符问题》:本文主要介绍解决IDEA报错:编码GBK的不可映射字符问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录IDEA报错:编码GBK的不可映射字符终端软件问题描述原因分析解决方案方法1:将命令改为方法2:右下jav

MySQL中的分组和多表连接详解

《MySQL中的分组和多表连接详解》:本文主要介绍MySQL中的分组和多表连接的相关操作,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录mysql中的分组和多表连接一、MySQL的分组(group javascriptby )二、多表连接(表连接会产生大量的数据垃圾)MySQL中的

Java 实用工具类Spring 的 AnnotationUtils详解

《Java实用工具类Spring的AnnotationUtils详解》Spring框架提供了一个强大的注解工具类org.springframework.core.annotation.Annot... 目录前言一、AnnotationUtils 的常用方法二、常见应用场景三、与 JDK 原生注解 API 的

Java controller接口出入参时间序列化转换操作方法(两种)

《Javacontroller接口出入参时间序列化转换操作方法(两种)》:本文主要介绍Javacontroller接口出入参时间序列化转换操作方法,本文给大家列举两种简单方法,感兴趣的朋友一起看... 目录方式一、使用注解方式二、统一配置场景:在controller编写的接口,在前后端交互过程中一般都会涉及

Java中的StringBuilder之如何高效构建字符串

《Java中的StringBuilder之如何高效构建字符串》本文将深入浅出地介绍StringBuilder的使用方法、性能优势以及相关字符串处理技术,结合代码示例帮助读者更好地理解和应用,希望对大家... 目录关键点什么是 StringBuilder?为什么需要 StringBuilder?如何使用 St