topic找不到

Question

运行下面的代码报异常

 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。是正常启动的。

Answer 1

阿神 2018-12-03 08:46:40

再create一个topic试试

• 提问者 ChlZhYa #1

  我在公司用windows发送消息是成功的。。我回去重新写个程序再试试。

• 提问者 ChlZhYa #2

  非常感谢！

Answer 2

提问者 ChlZhYa 2018-12-03 22:25:19

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

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