bootstrapupload opened a new issue, #5636: URL: https://github.com/apache/rocketmq/issues/5636
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()); } } -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
