fix(pulsar-query): 修复pulsar backlog获取错误

This commit is contained in:
2024-03-05 12:20:46 +08:00
parent 00257add00
commit 41d5a6b264

View File

@@ -273,7 +273,7 @@ public class PulsarQueryApplication {
.build()) {
Map<String, ? extends SubscriptionStats> subscriptions = admin.topics().getStats(topic).getSubscriptions();
if (ObjectUtil.isNotNull(subscriptions) && subscriptions.containsKey(subscription)) {
return subscriptions.get(subscription).getBacklogSize();
return subscriptions.get(subscription).getMsgBacklog();
}
return -1L;
}