Apache RocketMQ中发现是这个方法返回的是null造成的大佬帮忙看下？

Apache RocketMQ中发现是org.apache.rocketmq.proxy.service.sysmessage.AbstractSystemMessageSyncer#getRpcHook这个方法返回的是null造成的大佬帮忙看下？rocketmq5.1.1的proxy报如下错误： 2023-06-09 15:26:22 WARN RebalanceService - Compute consume offset from last offset exception, mq=MessageQueue [topic=DefaultHeartBeatSyncerTopic, brokerName=rocketmq-standalone-broker-0, queueId=0], exception={} org.apache.rocketmq.client.exception.MQClientException: Invoke Broker[10.244.134.179:10911] exception For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ at org.apache.rocketmq.client.impl.MQAdminImpl.maxOffset(MQAdminImpl.java:215) at org.apache.rocketmq.client.impl.consumer.RebalancePushImpl.computePullFromWhereWithException(RebalancePushImpl.java:185) at org.apache.rocketmq.client.impl.consumer.RebalancePushImpl.computePullFromWhere(RebalancePushImpl.java:158) at org.apache.rocketmq.client.impl.consumer.RebalanceImpl.updateProcessQueueTableInRebalance(RebalanceImpl.java:524) at org.apache.rocketmq.client.impl.consumer.RebalanceImpl.rebalanceByTopic(RebalanceImpl.java:305) at org.apache.rocketmq.client.impl.consumer.RebalanceImpl.doRebalance(RebalanceImpl.java:247) at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.doRebalance(DefaultMQPushConsumerImpl.java:1362) at org.apache.rocketmq.client.impl.factory.MQClientInstance.doRebalance(MQClientInstance.java:867) at org.apache.rocketmq.client.impl.consumer.RebalanceService.run(RebalanceService.java:41) at java.lang.Thread.run(Thread.java:750) Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 1 DESC: org.apache.rocketmq.acl.common.AclException: No accessKey is configured, org.apache.rocketmq.acl.plain.PlainPermissionManager.validate(PlainPermissionManager.java:607) BROKER: 10.244.134.179:10911 For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ at org.apache.rocketmq.client.impl.MQClientAPIImpl.getMaxOffset(MQClientAPIImpl.java:1232) at org.apache.rocketmq.client.impl.MQAdminImpl.maxOffset(MQAdminImpl.java:213) ... 9 common frames omitted

展开

收起

真的很搞笑 2023-06-11 23:04:09 539 0

4 条回答

写回答

取消提交回答

Skyund

这个错误可能是与RocketMQ代码中的网络延迟或其他问题有关。这个问题通常会导致在RocketMQ代理服务中的拉取消息出现错误，无法获取到主节点的最新消息。检查你的网络连接和代理服务是否正常工作，并检查你的代码中是否有错误。在你的代码中加入一些异常处理，比如检查try-catch语句，确保你的代码可以在发生异常时停止执行，以免对服务器产生不良影响。尝试重启你的代理服务，这有时可以解决网络延迟或其他问题。考虑升级到最新版本的RocketMQ，因为可能存在已知的问题和错误。

2023-06-20 09:43:33

赞同展开评论打赏
vohelon
根据您提供的信息，可以看出是在 RebalanceService 的 computePullFromWhere 方法中出现了错误，并且错误信息中提到没有配置 accessKey，可能是访问权限的问题导致的。

另外，您还提到 AbstractSystemMessageSyncer 类的 getRpcHook 方法返回了 null，这个方法是用来获取 Rpc Hook 的，如果返回 null 可能是配置问题导致的。您可以检查一下相关配置，确保配置正确，例如检查是否设置了正确的 accessKey 和 secretKey。

综上，建议您检查以下配置是否正确：
1. 检查是否正确配置了 accessKey 和 secretKey，可以查看 rocketmq.proerties 配置文件或者代码中是否包含设置的逻辑。
2. 检查 Rpc Hook 的配置是否正确，确保 getRpcHook 方法能够正确返回不为 null。
3. 检查相关网络设备和防火墙的配置，确保消息的通信和传输能够正常进行。
2023-06-12 08:58:22

赞同展开评论打赏
算精通

北京阿里云ACE会长

可以看出出现了 No accessKey is configured 的错误，这很可能是由于您的 RocketMQ 服务开启了 ACL 访问控制功能而导致的。

在 RocketMQ 中，通过 ACL 来对消息进行访问控制，保证消息的安全性。如果您的 RocketMQ 服务开启了 ACL 功能，那么在进行消息发送、消费、管理等操作时，需要提供相应的 accessKey 和 secretKey。如果缺少了这些访问控制参数，就会出现类似 No accessKey is configured 的错误。

针对这个问题，您可以尝试在 RocketMQ 的配置文件中添加相应的 ACL 配置信息，例如：

Copy acl.enable=true acl.plain.accessValidatorClass=org.apache.rocketmq.acl.plain.PlainAccessValidator acl.plain.permissionPath=/path/to/permission/file 其中，acl.enable 参数表示开启 ACL 功能，acl.plain.accessValidatorClass 参数表示访问控制的实现类，acl.plain.permissionPath 参数表示权限配置文件的路径。此外，还需要在进行消息发送、消费、管理等操作时，提供相应的 accessKey 和 secretKey。

需要注意的是，在开启 ACL 功能后，如果没有正确配置访问控制参数，就会出现类似 No accessKey is configured 的错误。因此，在使用 ACL 功能时，需要仔细检查配置文件和代码中的访问控制参数，确保其正确性。

2023-06-12 07:59:28

赞同展开评论打赏
穿过生命散发芬芳

根据报错信息，发现是在计算消费进度时出现了异常，具体是在使用代理服务进行消息同步时，调用了getRpcHook方法，但返回了null，导致后续调用失败。这个问题可能是由于某些配置或者代码问题引起的。建议检查配置文件和相关代码，看看是否有缺失或错误的配置项，或者是否缺少必要的依赖。

2023-06-12 07:57:14

赞同展开评论打赏