topic找不到
来源:3-1 生产者使用与管控台查询消息

ChlZhYa
2018-12-03
运行下面的代码报异常
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试试
022018-12-03 -
ChlZhYa
提问者
2018-12-03
我在百度上搜索 no route Info of this topic,有人说是因为没有加 fastjson 的 jar 包,所以我就在 pom 文件中加了 fastjson 的坐标,但是又漏了版本。然后之后就一直报这个错,今天在公司发送了一条消息,发现是成功的。回来仔细检查了一下项目。发现了这个问题。去掉错误之后,无论是否引入 fastjson 都可以执行成功。
可能主要就是中间不断重启关闭 mq的broker 和 namesrv 吧。
00
相似问题