消息队列 RocketMQ 版 客户端接入问题

[org.apache.rocketmq.client.exception.MQClientException: No route info of this topic: generation%rocketmq-gab9bb2877z8|generation%video_task
可能原因如下。

相关产品
消息队列 RocketMQ 版 产品页,含版本规格、价格与购买入口。

一、客户端返回“No route info of this topic”错误

详细报错如下:

topic_name 不对,检查一下命名空间是否正确,主题名的格式应该是rocketmq-xxx|[ns]%[topicName]。

·namespace 为命名空间的名称,在控制台命名空间页面复制。

·topic_name 在控制台集群管理中Topic 页签中复制具体 Topic 名称。

另外,其他可能的原因是:

·Broker 禁止自动创建 Topic,且用户没有通过手工方式在控制台创建 Topic。

·Broker 没有正确连接到 Name Server,请提交工单处理。

·Producer 没有正确连接到 Name Server,请检查接入点是否输入正确。

二、客户端异常“ Send [3] times, still failed, cost [334]ms”

详细报错如下:

com.freesky.inspiration.domain.mq.MQProducerManager:sendMessage [org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [334]ms, Topic: video_task, BrokersSent: [broker-2, broker-0, broker-1]

可能原因如下:

缺少权限,检查一下命名空间有没有授权。

三、4.x 客户端开启 VIPChannel 后连接集群异常“org.apache.rocketmq.remoting.exception.RemotingConnectException”

客户端开启 VIPChannel 后,SDK 会与 Broker 的一个指定端口建立连接进行消息收发,但该功能对云上集群不适用,开启后可能会出现连接失败等错误。如有遇到,需要在初始化时候关闭该特性:

// 生产端producer.setVipChannelEnabled(false);// 消费端consumer.setVipChannelEnabled(false);

赞 (0)
上一篇 4天前
下一篇 4天前