上云无忧 > 文档中心 > 腾讯云消息队列 RocketMQ 发送消息报错
消息队列 RocketMQ 版
腾讯云消息队列 RocketMQ 发送消息报错

文档简介:
客户 Producer 发消息失败,出现 ACL exception 的报错。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

客户 Producer 发消息失败,出现 ACL exception 的报错

		

Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE:

1 DESC: org.apache.rocketmq.acl.common.AclException: [PRODUCE] Token authentication

failed, please check, org.streamnative.pulsar.handlers.rocketmq.inner.RocketMQBroker

Controller$3.doBeforeRequest(RocketMQBrokerController.java:475)

For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:665)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:505)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:487)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:431)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:854)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:584)
... 3 more

可能原因如下:
AK SK 配置不正确。access-key/secret-key 配置不正确会抛出AclException
access-key:namespace 配置权限中的角色密钥。
secret-key:namespace 配置权限中的角色名称。

客户接入的时候报错 RemotingConnectException

		

Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to

[rocketmq-vsxssa.rocketmq.ap-gz.qcloud.tencenttdmq.com:5098] failed

at org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateNameserverChannel(NettyRemotingClient.java:445)
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateChannel(NettyRemotingClient.java:400)
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:369)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1363)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1353)
at org.apache.rocketmq.client.impl.factory.MQClientInstance.updateTopicRouteInfoFromNameServer(MQClientInstance.java:622)
... 6 more

大部分时候是接入点填写错误,接入点可以在集群基本信息页面的网络模块获取。
集群接入地址默认支持 VPC 内网访问。
集群公网接入地址,默认不开通。如需开通公网访问,虚拟集群可提交工单申请,专享集群可以通过调整公网带宽来开启/关闭公网访问。建议公网访问只在作为测试使用。
注意:
VPC 内网访问时,需要使用同一地域的 CVM 机器或者其他能成功访问 VPC 的环境。可使用 ping 或者 telnet 测试网络是否成功连接,网络不通时会抛出 RemotingConnectException 错误。
相似文档
  • 消费不到消息是什么原因? 消费不到消息有多种原因,常见的如下: 生产者启动在消费者启动之前:生产者启动在消费者启动之前,但是消费者 consumeFromWhere 配置错误会导致消费者从最新的位点开始消费。
  • RocketMQ 有两种常用的消费模式,Pull 和 Push,而 Push 模式的实现是基于 Pull 模式,只不过对 Pull 模式做了个包装,所以 RocketMQ Push 模式并不是真正意义上的推模式,还是拉模式。
  • 为使用腾讯云消息队列 RocketMQ 版服务(以下简称“本服务”),您应当阅读并遵守《消息队列 RocketMQ 版服务等级协议》(以下简称“本协议” 或“SLA”),以及《腾讯云服务协议》。本协议包含本服务的术语和定义、服务可用性/服务成功率等级指标、赔偿方案、免责条款等相关内容。请您务必审慎阅读、充分理解各条款内容,限制、免责条款或者其他涉及您重大权益的条款可能会以加粗、加下划线等形式提示您重点注意。
  • 消息队列 RabbitMQ 版(TDMQ for RabbitMQ,简称 TDMQ RabbitMQ 版)是一款腾讯自主研发的消息队列服务,支持 AMQP 0-9-1 协议,完全兼容开源 RabbitMQ 的各个组件与概念,同时具备计算存储分离,灵活扩缩容的底层优势。
  • 2024-03-14,Vhost 和用户命名取消“.” 字符限制。 2024-03-14,新增重庆地域。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部