org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest异常解决

  使用RocketMQ发送消息抛出异常,异常如下:

  

  原因:

  Broker 禁止自动创建Topic,且用户没有通过手动创建此Topic,或者broker 和 Nameserver网络不同;

  

  解决方案:

  1. 修改broker.properties配置,自动创建topic,添加如下:

autoCreateTopicEnable=true

  

  2. 升级RocketMQ版本为4.4.0,新版本会默认自动创建

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>4.3.0</version>
        </dependency>

  

原文地址:https://www.cnblogs.com/coder-zyc/p/12115317.html

时间: 2024-08-30 13:59:51

org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest异常解决的相关文章

日常填坑:org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

错误如下: 1 org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout 2 at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:634) ~[rocketmq-client-4.4.0.j

No route info of this topic

使用rocketmq时报错 com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic, topic-test 搜索原因,找到这几种解决方式 1: 在启动broker时,添加 autoCreateTopicEnable=true 如: mqbroker -n localhost:9876 autoCreateTopicEnable=true 2:检查lib下有无fastjson的jar包

org.apache.http.client.HttpClient使用方法

官网说明: http://hc.apache.org/httpclient-3.x/ Commons HttpClient项目现已结束,不再开发.它已被其HttpClient和HttpCore模块中的Apache HttpComponents项目所取代,它们提供更好的性能和更大的灵活性. 从2011年开始,org.apache.commons.httpclient就不再开发.这就是说,它已经落伍了. 方法的对称性上的区别 一.org.apache.http.client org.apache.h

jetty client 与apache http client的实现、分析

谈到httpclient的话,只要会想到apache的httpclient和jetty的httpclient,但是apache的httpclient3和4之间又有区别,通过学些,最终总结了三种方式使用HttpClient, 分别为使用httpclient3,httpclient4,jetty的httpclient,下面分别来贴代码: 第1种:使用的jar包为commons-httpclient-3.1,只需要一个jar包即可 这里使用的是GetMethod,与httpcleint4有区别 pub

apache.http.client.HttpClient

前言 HTTP 协议可能是现在 Internet 上使用得最多.最重要的协议了,越来越多的 Java 应用程序需要直接通过 HTTP 协议来访问网络资源.虽然在 JDK 的 java net包中已经提供了访问 HTTP 协议的基本功能,但是对于大部分应用程序来说,JDK 库本身提供的功能还不够丰富和灵活.HttpClient 是 Apache Jakarta Common 下的子项目,用来提供高效的.最新的.功能丰富的支持 HTTP 协议的客户端编程工具包,并且它支持 HTTP 协议最新的版本和

运行ava org.apache.axis.client.AdminClient时找不到org.apache.commons.logging.LogFactory

D:\Tomcat 5.0\webapps\axis\WEB-INF\classes>java org.apache.axis.client.AdminClie nt Exception in thread "main" java.lang.NoClassDefFoundError: org.apache.commons.lo gging.LogFactory at org.apache.axis.components.logger.LogFactory.class$(LogFa

org.apache.http.client.HttpClient get/post请求

请求步骤 1.创建httpclient 对象 2.创建 请求方式,构造函数的值为请求路径 3.调用1中对象的execute() 方法,参数为 2 的对象 4.获取请求响应数据 5.释放连接资源 6.处理数据 一.使用org.apache.http.client.HttpClient 的get请求来实现 1.请求核心代码: // 创建 httpclient 对象       HttpClient httpclient = new DefaultHttpClient();    //创建请求方式,因

解决Apache虚拟主机报错问题apache AH01630: client denied by server configuration错误解决方法

今天同事咨询通过Apache搭建创建虚拟主机,搭建好发现一直报错,提示 "apache AH01630: client denied by server configuration",在网上搜索了一下, 发现这个错误的原因是,apache2.4 与 apache2.2 的虚拟主机配置写法不同导致. apache2.2的写法: [plain] view plain copy 在CODE上查看代码片派生到我的代码片 <VirtualHost *:80> ServerName f

org.apache.http.client.CircularRedirectException: Circular redirect to &quot;http://xxx&quot;问题解决

org.apache.http.client.CircularRedirectException: Circular redirect to "http://xxx"问题解决 用HttpClient的时候遇到一个问题:org.apache.http.client.CircularRedirectException: Circular redirect to...解决方法如下: HttpParams params = new BasicHttpParams();  HttpGet get