[GitHub] [pulsar] startjava added a comment to the discussion: what time merge about this version ?

[GitBox]

GitHub user startjava added a comment to the discussion: what time merge about 
this version ?

use bottom code print info :
```
    @RequestMapping("getUnAckMsgCount")
    public String getUnAckMsgCount() throws PulsarClientException, 
PulsarAdminException {
        {
            List<? extends ConsumerStats> consumers = 
pulsarAdmin.topics().getStats(myTopic1).getSubscriptions().get(myTopic1_subscriptionName).getConsumers();
            for (int i = 0; i < consumers.size(); i++) {
                ConsumerStats consumerStats = consumers.get(i);
                System.out.println(myTopic1 + " getConsumerName=" + 
consumerStats.getConsumerName() + " getUnackedMessages=" + 
consumerStats.getUnackedMessages());
            }
        }
        System.out.println();
        {
            List<? extends ConsumerStats> consumers = 
pulsarAdmin.topics().getStats(myTopic2).getSubscriptions().get(myTopic2_subscriptionName).getConsumers();
            for (int i = 0; i < consumers.size(); i++) {
                ConsumerStats consumerStats = consumers.get(i);
                System.out.println(myTopic2 + " getConsumerName=" + 
consumerStats.getConsumerName() + " getUnackedMessages=" + 
consumerStats.getUnackedMessages());
            }
        }
        return "成功获得";
    }
```


GitHub link: 
https://github.com/apache/pulsar/discussions/17978#discussioncomment-3844937

----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@pulsar.apache.org