哪个API可以获得未ACK消息的数量?
因为我想通过此API,看看普通Ack和累积ACK的区别,
感谢;
可以通过admin api的client获取:
try (PulsarAdmin admin = PulsarAdmin.builder().serviceHttpUrl("http://127.0.0.1:8080").authentication("org.apache.pulsar.client.impl.auth.AuthenticationToken","token:xxxx").build();){
String topicName = "persistent://public/default/test";
Topics topics = admin.topics();
TopicStats stats = topics.getStats(topicName);
Map<String, ? extends SubscriptionStats> subs = stats.getSubscriptions();
//${subscription_name} 是对应订阅的名称
SubscriptionStats subscriptionStats = subs.get("${subscription_name}");
long unackmessagenums = subscriptionStats.getUnackedMessages();
} catch (PulsarClientException | PulsarAdminException e) {
throw new RuntimeException(e);
}
thank fujun !what time merge about this version ? · Discussion #17978 · apache/pulsar · GitHub
future version not 0 ,but current version is 0.