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 [email protected].
To unsubscribe, please send an email to: [email protected]
