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回答

阿神

2018-12-03

再create一个topic试试

0
2
ChlZhYa
非常感谢!
2018-12-03
共2条回复

ChlZhYa

提问者

2018-12-03

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

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

0
0

RocketMQ核心技术精讲与高并发抗压实战

理论+实战,系统掌握RocketMQ核心技术, 挑战高并发抗压实战

1182 学习 · 304 问题

查看课程