>mqadmin queryMsgByUniqueKey execute error

[quanzhou88]

Runtime platform environment
Windows 11 家庭中文版 22H2

RocketMQ version
server version: 5.2.0
java client version: 5.0.6

JDK Version
openjdk version "11.0.20"

Describe the problem
I created a Java consumer，The consumer can accept message successfully, but i can't use ./mqadmin consumerProgress to query the consume process. Here is the error:

>mqadmin queryMsgByUniqueKey -n 127.0.0.1:9876 -t WY_MESSAGE_TOPIC  -g backstage_consume -i 01202B20616AF570B005F9677700000001
Topic:               WY_MESSAGE_TOPIC
Tags:                [wy_wx_tag]
Keys:                [2222222222]
Queue ID:            4
Queue Offset:        203
CommitLog Offset:    7211635
Reconsume Times:     0
Born Timestamp:      2024-03-06 09:57:11,061
Store Timestamp:     2024-03-06 09:57:14,060
Born Host:           192.168.0.30:55312
Store Host:          192.168.0.30:10911
System Flag:         0
Properties:          {TIMER_OUT_MS=1709690233000, MSG_REGION=DefaultRegion, TIMER_DELIVER_MS=1709690233034, UNIQ_KEY=01202B20616AF570B005F9677700000001, CLUSTER=DefaultCluster, PGROUP=WY_MESSAGE_TOPIC, RECONSUME_TIME=0, TIMER_ENQUEUE_MS=1709690231000, TAGS=wy_wx_tag, __BORNHOST=wl1113, BORN_TIMESTAMP=1709690231061, KEYS=2222222222, TRACE_ON=true, TIMER_DEQUEUE_MS=1709690234059, REAL_TOPIC=WY_MESSAGE_TOPIC, REAL_QID=4}
Message Body Path:   /tmp/rocketmq/msgbodys/01202B20616AF570B005F9677700000001


MessageTrack [consumerGroup=backstage_consumer, trackType=UNKNOWN, exceptionDesc=org.apache.rocketmq.client.exception.MQClientException: CODE: 17  DESC: No topic route info in name server for the topic: %RETRY%backstage_consumer
See https://rocketmq.apache.org/docs/bestPractice/06FAQ for further details., org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:2011)]

But check the consumption status of the subscription group normal

>mqadmin consumerProgress -n  127.0.0.1:9876 -g backstage_consumer  -t WY_MESSAGE_TOPIC
#Topic                                                            #Broker Name                      #QID  #Broker Offset        #Consumer Offset      #Diff                #Inflight           #LastTime
WY_MESSAGE_TOPIC                                                  wl1113                            0     8
        8                     0                    0                    2024-03-05 18:06:57
WY_MESSAGE_TOPIC                                                  wl1113                            1     210
        210                   0                    0                    2024-03-01 17:25:39
WY_MESSAGE_TOPIC                                                  wl1113                            2     202
        202                   0                    0                    2024-03-06 09:16:09
WY_MESSAGE_TOPIC                                                  wl1113                            3     196
        196                   0                    0                    2024-03-01 14:57:51
WY_MESSAGE_TOPIC                                                  wl1113                            4     204
        204                   0                    0                    2024-03-06 09:57:14
WY_MESSAGE_TOPIC                                                  wl1113                            5     197
        197                   0                    0                    2024-03-01 17:37:35
WY_MESSAGE_TOPIC                                                  wl1113                            6     2
        2                     0                    0                    2024-03-01 16:46:31
WY_MESSAGE_TOPIC                                                  wl1113                            7     203
        203                   0                    0                    2024-03-01 15:46:39

Consume TPS: 0.02
Consume Diff Total: 0
Consume Inflight Total: 0

Consumer code

  ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfigurationBuilder clientConfigurationBuilder = ClientConfiguration.newBuilder()
                //mq5.1以上版本默认使用代理（proxy）地址连接，默认端口8081
                .setEndpoints(endpoints)
                .enableSsl(false);
        if (StrUtil.isNotBlank(accessKey)){
            SessionCredentialsProvider sessionCredentialsProvider = new StaticSessionCredentialsProvider(accessKey, secretKey);
            clientConfigurationBuilder.setCredentialProvider(sessionCredentialsProvider);
        }
        ClientConfiguration configuration = clientConfigurationBuilder.build();
        try {
            FilterExpression filterExpression = new FilterExpression(messageTag, FilterExpressionType.TAG);
            provider.newPushConsumerBuilder()
                    .setClientConfiguration(configuration)
                    // 设置消费者分组。
                    .setConsumerGroup(messageGroup)
                    // 设置预绑定的订阅关系。
                    .setSubscriptionExpressions(Collections.singletonMap(messageTopic, filterExpression))
                    // 设置消费监听器。
                    .setMessageListener((MessageView messageView)->{
                        String str = StandardCharsets.UTF_8.decode(messageView.getBody()).toString();

                        log.info("接收到，topic:{},tag:{},group:{},id：{},内容：{}",messageView.getTopic(),messageView.getTag(),messageView.getMessageGroup() ,messageView.getMessageId(), str);
                        return ConsumeResult.SUCCESS;
                    }).build();
            log.info("building consumers success：proxy:{}, topic:{},tag:{}, group：{}", endpoints, messageTopic, messageTag, messageGroup);
        } catch (ClientException e) {
            log.error("building consumers fail：proxy:{}, topic:{},tag:{}, group：{}", endpoints, messageTopic, messageTag, messageGroup, e);
        }

[leizhiyuan]

这个方法最后会查询轨迹，这里查询轨迹需要用到retry topic来做路由，5.0 含有proxy的部署模式，产生的retry topic不是这个， 所以没有路由。

[quanzhou88]

那请问还有其他方式查询 ，消息是否被消费吗？

[leizhiyuan]

把这个重试队列在服务端建出来，可以绕过这个问题。

%RETRY%backstage_consumer

[quanzhou88]

好的，谢谢