no topic route info in name server for the topic_no route info of this topic,_no route info of this topic - 腾讯云开发者社区

前言用过rocketmq的人，采用客户端调用的时候，可能会相对高频的出现的 No route info of this topic这个异常问题，然后你可能会拿着这个问题，直接谷歌百度一把，会发现网上告诉你的答案...Route Info”, how to diagnose?...Producer complains “No Topic Route Info”, how to diagnose?...Make sure that the producer can connect to a name server and is capable of fetching routing meta info...You may query the routing meta info from name server through topicRoute using admin tools or web console

48K7 1

解决RocketMQ报No route info of this topic：异常

目前rocketmq 被使用的概率大大提升，相信很多朋友也都想着去试试，在测试的过程中根据官网给出的案例，应该有部分朋友遇到过这个异常： No route info of this topic，然后上网查询结果...解决呢 public static void main(String[] args) throws Exception{ //Instantiate with a producer group name...DefaultMQProducer producer = new DefaultMQProducer("group"); // Specify name server addresses...i++) { final int index = i; //Create a message instance, specifying topic

4.6K2 0

您找到你想要的搜索结果了吗？

是的

没有找到

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

org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest See http...，且用户没有通过手工方式创建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

5.7K2 0

org.apache.rocketmq.client.exception.MQClientException: No route info of this topic

info of this topic”异常，win10本地启动同版本的rocketmq release库没有任何问题，搜索了许久仍然没有找到问题，关于这个问题，部分原因在笔者，笔者没有完全按照http...RemotingException, InterruptedException, MQBrokerException { //Instantiate with a producer group name...引入rocketmq-spring-boot-starter引入后导致MQClientInstance实例被提前创建，提前创建使用的是application.yml文件中配置： rocketmq: name-server...info of this topic"这个异常，搜索了很多最终都没有解决问题，最终单步调试解决了该问题。...info of this topic“这个错误 2、引入rocketmq-spring-boot-starter以来时不要使用DefaultMQProducer发送信息

2.9K2 0

【已解决】RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic

RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic xxx 错误提示是说，没有xxx这个topic....出现topic不存在，主要有以下三种情况导致的：第一种：broker中真的没有xxx这个topic....可以登录rockermq控制台查看：可以搜索topic。或者查看broker的日志确定topic是否真的存在。...=recommend 出现如下内容说明topic已经存在：图片如果没有出现以上内容，说明topic确实不存在。...可以通过自动创建topic或者手动创建topic解决问题。自动创建topic：可以在启动broker启动脚本添加自动创建topic参数。

3.1K2 0

Apache RocketMQ 消息队列部署与可视化界面安装

MQClientException: No route info of this topic, TopicTest1 4.1.1....异常说明在客户端的Producer运行起来准备发送消息时抛异常为 “ No route info of this topic ” 异常产生的原因可能是： Broker 禁止自动创建 Topic，且用户没有通过手工方式创建...Topic Broker 没有正确连接到 Name Server Producer 没有正确连接到 Name Server 4.1.2....没有正确连接到 Name Server 检查程序连接Name Server的地址有没有错如果在云服务器上，检查安全组的配置9876端口有没有开发看看有没有打开防火墙，有的话设置防火墙开放9876端口...异常说明在客户端的 Producer 运行起来准备发送消息时抛异常如下通常因为Name Server连接不上Broker ? 4.2.2.

3K5 0

RocketMQ Message相关命令【实战笔记】

printMsg -n 192.168.1.x:9876 -t SCANRECORD "t", "topic", true, "topic name" "c", "charsetName ", true...route info in name server for the topic: %RETRY%dpmComScanRecordConsumer See [http://rocketmq.apache.org...route info in name server for the topic: %RETRY%dpmComScanRecordConsumer See [http://rocketmq.apache.org...", true, "topic name" "b", "brokerName", true, "Broker Name" "i", "queueId", true, "Queue Id" "o", "offset...route info in name server for the topic: %RETRY%dpmComScanRecordConsumer See [http://rocketmq.apache.org

2.7K3 0

RouteInfoManager#pickupTopicRouteData的调用方法

路由，那么reponseCode为TOPIC_NOT_EXIST response.setCode(ResponseCode.TOPIC_NOT_EXIST); response.setRemark...("No topic route info in name server for the topic: " + requestHeader.getTopic()...+ FAQUrl.suggestTodo(FAQUrl.APPLY_TOPIC_URL)); return response; } 结合这两个方法，我们可以总结出查找Topic路由主要分为3个步骤...如果topic为顺序消息，那么从KVconfig中获取关于顺序消息先关的配置填充到orderTopicConf中。...如果找不到路由信息，那么返回code为ResponseCode.TOPIC_NOT_EXIST。

8502 0

排查1：Broker 禁止自动创建 Topic，且用户没有通过手工方式创建 Topic

二：Broker模块没有正确连接到Name Server 三：Producer没有正确连接到Name Server 办法排查1：Broker 禁止自动创建 Topic，且用户没有通过手工方式创建 Topic...main - transientStorePoolEnable=false [root@localhost apache-rocketmq]# 排查2：Broker 没有正确连接到 Name Server...to name server localhost:9876 OK 2018-08-11 23:48:31 INFO main - Start transaction service!...serializeType=JSON and name server is localhost:9876 2018-08-11 23:48:41 INFO BrokerControllerScheduledThread1...name server localhost:9876 OK 排查3：Producer 没有正确连接到 Name Server 如果按前两步检查没有问题，但启动还是报错，那就只剩下第三种情况了，最大可能是发送者和

1.8K1 0

聊聊rocketmq的updateTopicRouteInfoFromNameServer

} else { log.info("the topic[{}] route info changed, old[{}] ,new[{}]", topic...("new name server is chosen....server channel exception", e); } finally { this.lockNamesrvChannel.unlock...(); } } else { log.warn("getAndCreateNameserverChannel: try to lock name...server, but timeout, {}ms", LOCK_TIMEOUT_MILLIS); } return null; } private

3K0 0

RabbitMQ之topic（主题）Exchange解读

（主题）Exchange主题交换的主要关注点在路由键，路由键通常是由零个或者多个有意义的单词通过点号( . )分隔拼接而成，类似于： topic.route.one ，topic.route，topic....#.#* ， topic.route.#.# ，topic.route.*# ， topic.route.one ， # ，* 等等使用场景模糊匹配进行消息的传播，例如给用户推送新闻的时候，可以采用用户搜索过的关键字进行模糊匹配推送...演示架构编辑生产者发送消息道topic交换机上面，队列A和队列B绑定一个topoc交换机，对于队列a来说，它绑定的key为info.#，对于队列b来说，它绑定的key为info.*。...org.projectlombok lombok application.yml配置文件如下：server...: queue.topic.b接收到消息:hello world(info.xxxooo)2023-09-26 22:20:46.716 INFO 42376 --- [ntContainer

3026 1

SpringBoot整合RabbitMQ 实现五种消息模型

org.springframework.boot spring-boot-starter-amqp 配置配置文件 server...: port: 9090 spring: application: # 微服务系统有意义, 养成好习惯, 先写出来 name: rabbitmq-02-springboot...public void receive2(String message) { System.out.println("message2 = " + message); } } 第四种 Route...路由模型开发生产者 /** * route 路由 */ @Test void testRoute() { // exchange 交换机名称...rabbitTemplate.convertAndSend("directs", "info", "info的key的路由消息"); } 开发消费者 /** * @author

7343 0

spring-boot-route（十五）整合RocketMQ

一个 Topic 下可以设置多个消息队列，发送消息时执行该消息的 Topic ，RocketMQ 会轮询该 Topic 下的所有队列将消息发出去。 Spring Boot整合Rocketmq 1....配置rocketmq信息 rocketmq: name-server: 127.0.0.1:9876 producer: group: my-producer-group 3....implements RocketMQListener { @Override public void onMessage(String message) { log.info... 此是spring-boot-route系列的第十五篇文章，这个系列的文章都比较简单，主要目的就是为了帮助初次接触Spring Boot 的同学有一个系统的认识。...github:https://github.com/binzh303/spring-boot-route

8292 1

Dapr 入门教程之发布订阅

: "A", route: "A", }, { pubsubname: "pubsub", topic: "B", route: "B",...']) def subscribe(): subscriptions = [{ 'pubsubname': 'pubsub', 'topic': 'A', 'route': 'A...' }, { 'pubsubname': 'pubsub', 'topic': 'C', 'route': 'C' }] return jsonify(subscriptions...要使用 Dapr 来发布消息，同样也是直接使用 Dapr 提供的 API 端点 http://localhost:/publish// 即可，...发布订阅通常用于需要高度可伸缩的大型应用程序，发布和订阅应用程序通常比传统的 client/server 应用程序具有更好的伸缩性。

1.6K4 0

记在使用rocketmq client客户端过程中踩到的坑

spm=a2c4g.11186623.6.540.afd02578y4vHe4 本文主要记录在使用rocketmq client时，遇到的一些坑，作者采用的客户端版本是4.2 踩到的坑 1、No route...info of this topic 遇到这种情况的原因可能有 1、Broker禁止自动创建Topic，且用户没有通过手工方式创建Topic 解决方案在启动broker时加上 autoCreateTopicEnable...Server 解决方案查看broker.log 日志信息 3、Producer没有正确连接到Name Server 解决方案切换到rocketmq的bin目录，执行 sh mqadmin clusterList...-n 安装rocketmqip地址:9876 如果出现 #Cluster Name #Broker Name #BID #Addr #...: Name, BrokersSent: [broker-a, broker-a, null] 1、如果出现开始发送消息成功，消费者接收消息后，再发送消息的话，出现上诉异常，则有很大概率是机器磁盘空间不足

14.9K3 1

RocketMQ学习-消息发布和订阅

屏幕快照 2018-03-31 14.50.41.png 在部署RocketMQ的时候，先启动name server，再启动broker，这时候broker会将自己注册到name server。...server拉取一次broker集群的地址，这意味着如果某个broker宕机了，生产者在这两分钟之内的消息是投递失败的；定期从name server拉取topic等路由信息；定期清理失效的broker...(ClientErrorCode.NO_NAME_SERVER_EXCEPTION); } throw new MQClientException("No route...info of this topic, " + msg.getTopic() + FAQUrl.suggestTodo(FAQUrl.NO_TOPIC_ROUTE_INFO),...nameServer的地址：name server地址，用于获取broker、topic信息消费者Demo里做了以下几个事情：设置配置属性设置订阅的topic，可以指定tag 设置第一次启动的时候

5.9K2 0

聊聊rocketmq的retryAnotherBrokerWhenNotStoreOK

= null) { return sendResult; } String info = String.format("...(null == nsList || nsList.isEmpty()) { throw new MQClientException( "No name...server address, please set it." + FAQUrl.suggestTodo(FAQUrl.NAME_SERVER_ADDR_NOT_EXIST_URL), null).setResponseCode...(ClientErrorCode.NO_NAME_SERVER_EXCEPTION); } throw new MQClientException("No route...info of this topic, " + msg.getTopic() + FAQUrl.suggestTodo(FAQUrl.NO_TOPIC_ROUTE_INFO),

1.3K2 0

RocketMQ消息发送【源码笔记】（一）

please." + FAQUrl.suggestTodo(FAQUrl.GROUP_NAME_DUPLICATE_URL), null);...please." + FAQUrl.suggestTodo(FAQUrl.GROUP_NAME_DUPLICATE_URL), null);...server address, please set it." + FAQUrl.suggestTodo(FAQUrl.NAME_SERVER_ADDR_NOT_EXIST_URL), null).setResponseCode...(ClientErrorCode.NO_NAME_SERVER_EXCEPTION); } //发送抛错没有找到Topic路由信息 throw new MQClientException...("No route info of this topic, " + msg.getTopic() + FAQUrl.suggestTodo(FAQUrl.NO_TOPIC_ROUTE_INFO),

2.1K2 0

Apache RocketMQ 安装、测试、报错解决

mqbroker > nohup sh bin/mqnamesrv & > tail -f ~/logs/rocketmqlogs/namesrv.log 运行成功的日志输出： The Name...Server boot success......Java Runtime Environment to continue 2）报错：org.apache.rocketmq.client.exception.MQClientException: No route...info of this topic, TopicTest 解决方式：解决：org.apache.rocketmq.client.exception.MQClientException: No route...info of this topic, TopicTest 3）报错：Could not find or load main class org.apache.rocketmq.example.quickstart.Producer

1.1K2 0

kafka系列之camel-kafka

唯一要注意的是 kafka server 的版本最好跟 camel-kafka 引入的 kafka-client 版本一致，以免踩坑。...integration2..."); CamelContext camelContext = new DefaultCamelContext(); // Add route...pc.setLocation("classpath:application.properties"); System.out.println("About to start route...: Kafka Server -> Log "); from("kafka:{{consumer.topic}}?...}}").log(LoggingLevel.INFO, "${headers}"); // Topic can be set in header as well.

4.8K3 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

Rocketmq之No route info of this topic解决思路

解决RocketMQ报No route info of this topic：异常

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

org.apache.rocketmq.client.exception.MQClientException: No route info of this topic

【已解决】RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic

Apache RocketMQ 消息队列部署与可视化界面安装

RocketMQ Message相关命令【实战笔记】

RouteInfoManager#pickupTopicRouteData的调用方法

排查1：Broker 禁止自动创建 Topic，且用户没有通过手工方式创建 Topic

聊聊rocketmq的updateTopicRouteInfoFromNameServer

RabbitMQ之topic（主题）Exchange解读

SpringBoot整合RabbitMQ 实现五种消息模型

spring-boot-route（十五）整合RocketMQ

Dapr 入门教程之发布订阅

记在使用rocketmq client客户端过程中踩到的坑

RocketMQ学习-消息发布和订阅

聊聊rocketmq的retryAnotherBrokerWhenNotStoreOK

RocketMQ消息发送【源码笔记】（一）

Apache RocketMQ 安装、测试、报错解决

kafka系列之camel-kafka

扫码

相关资讯

热门标签

活动推荐

运营活动

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐