前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >RocketMQ报错No route info of this topic解决方案

RocketMQ报错No route info of this topic解决方案

作者头像
traffic
发布2020-04-09 15:25:16
5.4K0
发布2020-04-09 15:25:16
举报
文章被收录于专栏:大龄码农大龄码农
org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest
See http://rocketmq.apache.org/docs/faq/ for further details.
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:610)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1223)
	at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1173)
	at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
	at com.ProducerTest01.main(ProducerTest01.java:46)

Broker禁止自动创建Topic,且用户没有通过手工方式创建Topic

官方文档中启动 Broker是这样的:

nohup sh bin/mqbroker -n localhost:9876 &

其实我们可以改成这样:

nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &

红字意思(允许自动创建Topic,且允许通过手工方式创建Topic)

客户端的 Producer 没有正确连接到Name Server

        //Instantiate with a producer group name.
        DefaultMQProducer producer = DefaultMQProducer("traffic_group");
        // Specify name server addresses.
        producer.setNamesrvAddr("localhost:9876");

检查producer的地址是否正确

缺少 Fastjson 的jar包

(由于本次使用的老项目环境,并没有整合maven一起使用,是每个每个jar的慢慢找的,所以才会导致这个缺包的问题)

添加 Fastjson jar包后成功

SendResult [sendStatus=SEND_OK, msgId=C0A803B13AE074A14FED747604D20000, offsetMsgId=C0A820ED00002A9F000000000002BEB2, messageQueue=MessageQueue [topic=TopicTest, brokerName=localhost.localdomain, queueId=0], queueOffset=250]
SendResult [sendStatus=SEND_OK, msgId=C0A803B13AE074A14FED7476050B0001, offsetMsgId=C0A820ED00002A9F000000000002BF64, messageQueue=MessageQueue [topic=TopicTest, brokerName=localhost.localdomain, queueId=1], queueOffset=250]
SendResult [sendStatus=SEND_OK, msgId=C0A803B13AE074A14FED747605120002, offsetMsgId=C0A820ED00002A9F000000000002C016, messageQueue=MessageQueue [topic=TopicTest, brokerName=localhost.localdomain, queueId=2], queueOffset=250]
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
    • nohup sh bin/mqbroker -n localhost:9876 &
      • nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档