【已解决】RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic
RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic xxx
错误提示是说,没有xxx这个topic.
出现topic不存在,主要有以下三种情况导致的:
第一种:broker中真的没有xxx这个topic.
可能原因:Broker模块不支持自动创建topic,并且xxxtopic也没有被手动创建多
第二种:borker模块没有正确连接到NAMESRV
第三种:发送者没有连接到NAMESRV
知道了产生原因,我们就来解决办法:
第一种情况查看topic是否正的存在。可以登录rockermq控制台查看:
可以搜索topic。
或者查看broker的日志确定topic是否真的存在。
登录MQ所在的服务器机器上,执行如下命令(注意:把recommend换成你自己的topic名称)
cat ~/logs/rocketmqlogs/broker.log | grep topicName=recommend
出现如下内容说明topic已经存在:
如果没有出现以上内容,说明topic确实不存在。可以通过自动创建topic或者手动创建topic解决问题。
自动创建topic:可以在启动broker启动脚本添加自动创建topic参数。或者在启动时候指定broker.conf配置文件中添加:
autoCreateTopicEnable=true
表示自动创建topic.
或者手动创建topic。
手动创建topic的话,可以直接在控制台创建。凯哥就不演示了。
第二种情况出现的概率极低。可以采用以下两种方式确认
1. 查看broker的日志,出现如下内容,说明连接成功。
查看日志命令 cat ~/logs/rocketmqlogs/broker.log | grep register
2. 在mq的安装目录执行如下命令
mqadmin clusterList -n localhost:9876
出现如下内容说明连接成功,没有问题
第三种情况出现的最大可能是发送者和mq服务器之间的网络或端口不通,可以使用ping或者telnet确定问题。如果ping或者telnet连接不通,需要联系运维工程师开通网络或端口权限
凯哥遇到的是第一种情况,topic确实不存在,是通过手动创建topic解决的
相关文章
- 分布式系统–拜占庭将军问题(The Byzantine Generals Problem)
- idea中启动SSM项目
- 【编程】给定一个部门,变量出当前部门的所有父部门包含当前部门
- 【解疑】ConcurrentHashMap 在JDK1.7时候put或get时候,怎么定位到数据的?
- Spring的BeanFactoryPostProcessor
- spring注解开发AnnotationConfigApplicationContext的使用
- 匿名内部类方式实现线程的创建
- spring异常:No runnable methods 解决方法
- 基础IO的理解与操作 - fd
- 【图文教程】Centos 7下安装Hadoop-管杀管埋的
- 【Flink教程-已解决】在idea中测试flink的时候,提示读取文件时候错误,提示文件不存在解决方案
- frp 服务器端 frps 一键安装卸载脚本
- 【Docker学习系列】Docker学习1-docker安装
- 高效、灵活、可自定义,腾讯云即时通信IM本地审核功能上线
- 新知 | 腾讯云视立方播放器技术实现与应用
- 云点播智能降码,成本与观看体验兼得的降本增效法宝
- 【Docker学习系列】Docker学习3-docker的run命令干了什么?docker为什么比虚拟机快?
- 【Docker学习教程系列】8-如何将本地的Docker镜像发布到私服?
- 「Docker学习系列教程」9-Docker容器数据卷介绍
- 「Docker学习系列教程」10-Docker容器数据卷案例