请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

topic找不到

运行下面的代码报异常

 public static final String NAMESRV_ADDR = "129.204.5.113:9876";

Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, test_quick_topic
See http://rocketmq.apache.org/docs/faq/ for further details.
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:634)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1253)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1203)
	at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
	at com.zcl.rocketmq.quickstart.Producer.main(Producer.java:30)

但是这个队列已经存在。
图片描述

使用telnet 命令也可以连接上。
这个问题已经纠结很久了。希望老师能指点一下哪里有毛病。也查看过broker.log。是正常启动的。

正在回答

2回答

再create一个topic试试

0 回复 有任何疑惑可以回复我~
  • 提问者 ChlZhYa #1
    我在公司用windows发送消息是成功的。。我回去重新写个程序再试试。
    回复 有任何疑惑可以回复我~ 2018-12-03 16:41:45
  • 提问者 ChlZhYa #2
    非常感谢!
    回复 有任何疑惑可以回复我~ 2018-12-03 22:25:27
提问者 ChlZhYa 2018-12-03 22:25:19

我在百度上搜索 no route Info of this topic,有人说是因为没有加 fastjson 的 jar 包,所以我就在 pom 文件中加了 fastjson 的坐标,但是又漏了版本。然后之后就一直报这个错,今天在公司发送了一条消息,发现是成功的。回来仔细检查了一下项目。发现了这个问题。去掉错误之后,无论是否引入 fastjson 都可以执行成功。

可能主要就是中间不断重启关闭 mq的broker 和 namesrv 吧。

0 回复 有任何疑惑可以回复我~
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信