网站首页 > 技术文章 正文
背景
用 producer 发消息时,报 No route info of this topic 错误:
org.apache.rocketmq.client.exception.MQClientException: No route info of this topic
See http://rocketmq.apache.org/docs/faq/ for further details.
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:662) ~[rocketmq-client-4.5.2.jar!/:4.5.2]
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.access$300(DefaultMQProducerImpl.java:90) ~[rocketmq-client-4.5.2.jar!/:4.5.2]
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl$3.run(DefaultMQProducerImpl.java:491) ~[rocketmq-client-4.5.2.jar!/:4.5.2]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_262]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_262]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_262]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_262]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_262]
这个错误网上说是由于 Broker 未启用自动创建 Topic 开关造成的,解决办法是在启动 Broker 时指定 autoCreateTopicEnable=true 即可。
例如:
nohup sh mqbroker -n xxxip:9876 autoCreateTopicEnable=true
其实这个说法并不靠谱,即使配置了autoCreateTopicEnable=true 还是会报这个错误,其实还有别的原因也有可能报 No route info of this topic 错误。
问题原因出在使用 sh mqbroker -n xxxip:9876 启动 mqborker 时候,如果 xxip 是内网 IP,否则也会报 No route info of this topic 错误。
所以解决办法就是把 xxip 改成 公网IP即可,修改方式有两种: 1、在 sh mqbroker 命令指定
nohup sh bin/mqbroker -n 公网IP:9876 autoCreateTopicEnable=true &
2、在 conf/broker.conf 中 加入 brokerIP1=公网IP 以及 autoCreateTopicEnable=true
brokerIP1=公网IP
autoCreateTopicEnable=true
推荐完整命令
- 启动 mqnamesrv
nohup sh /app/rocketmq-4.8.0/bin/mqnamesrv &
- 启动 mqbroker
nohup sh /app/rocketmq-4.8.0/bin/mqbroker -c /app/rocketmq-4.8.0/conf/broker.conf &
后台私信回复 1024 免费领取 SpringCloud、SpringBoot,微信小程序、Java面试、数据结构、算法等全套视频资料。
猜你喜欢
- 2025-01-23 记录:RocketMQ在使用上的一些排坑和优化
- 2025-01-23 消息队列选型(RabbitMq、RocketMq、Kafaka)
- 2025-01-23 Modbus新手教程(modbusrtu)
- 2025-01-23 性能调优篇:困扰我半年之久的RocketMQ timeout exception 被破解了
- 2025-01-23 RocketMQ - 如何实现顺序消息(rocketmq+-+如何实现顺序消息功能)
- 2025-01-23 10 张图 | 一文带你用 Mac M1 跑 RocketMQ
- 2025-01-23 RocketMQ - RocketMQ集群可视化的监控和管理
- 2025-01-23 RocketMQ中的线程池是如何创建的?
- 2025-01-23 手把手教你,从零开始搭建Spring Cloud Alibaba!这份笔记太牛了
- 2025-01-23 RocketMQ每秒要写入几十万并发,是怎么实现的?
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- oraclesql优化 (66)
- 类的加载机制 (75)
- feignclient (62)
- 一致性hash算法 (71)
- dockfile (66)
- 锁机制 (57)
- javaresponse (60)
- 查看hive版本 (59)
- phpworkerman (57)
- spark算子 (58)
- vue双向绑定的原理 (68)
- springbootget请求 (58)
- docker网络三种模式 (67)
- spring控制反转 (71)
- data:image/jpeg (69)
- base64 (69)
- java分页 (64)
- kibanadocker (60)
- qabstracttablemodel (62)
- java生成pdf文件 (69)
- deletelater (62)
- com.aspose.words (58)
- android.mk (62)
- qopengl (73)
- epoch_millis (61)
本文暂时没有评论,来添加一个吧(●'◡'●)