Closed bootstrapupload closed 10 months ago
IMO, Code in PlainAccessValidator has nothing to do with this question, take a look at you client log may be give you more info.
IMO, Code in PlainAccessValidator has nothing to do with this question, take a look at you client log may be give you more info.
If aclEnable is set to false,query message by key is normal, and aclEnable is true, i modify the local code, it is normal So I guess it has something to do with PlainAccessValidator
this is error info,“CODE: 208 DESC: query message by key finished, but no message” is from client,not the server, the server returns the following information
This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.
This issue was closed because it has been inactive for 3 days since being marked as stale.
this is error info,“CODE: 208 DESC: query message by key finished, but no message” is from client,not the server, the server returns the following information
Have you solved this problem? I have the same problem.
error info: org.apache.rocketmq.client.exception.MQClientException: CODE: 208 DESC: query message by key finished, but no message. For more information, please visit the url, http://rocketmq.apache.org/docs/faq/ at org.apache.rocketmq.client.impl.MQAdminImpl.queryMessage(MQAdminImpl.java:444) at org.apache.rocketmq.client.impl.MQAdminImpl.queryMessageByUniqKey(MQAdminImpl.java:281) at org.apache.rocketmq.client.impl.MQAdminImpl.queryMessageByUniqKey(MQAdminImpl.java:287) at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.viewMessage(DefaultMQAdminExtImpl.java:351) at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.viewMessage(DefaultMQAdminExt.java:559) rocketmq version:4.9.4 brokerConfig:aclEnable=true execute queryMessageByUniqKey(),aclEnable = true and MQClientAPIImpl#queryMessage RemotingCommand addExtField _UNIQUE_KEY_QUERY,because Client generating acl Signature by RemotingCommand, but Server parses RemotingCommand,exclude extField "_UNIQUE_KEY_QUERY",result in Server signature is not equals Client
Server code:PlainAccessValidator# // Content SortedMap<String, String> map = new TreeMap<String, String>(); for (Map.Entry<String, String> entry : request.getExtFields().entrySet()) { if (!SessionCredentials.SIGNATURE.equals(entry.getKey()) && !MixAll.UNIQUE_MSG_QUERY_FLAG.equals(entry.getKey())) { map.put(entry.getKey(), entry.getValue()); } }