diff --git a/service-pulsar-query/src/main/java/com/lanyuanxiaoyao/service/pulsar/PulsarQueryApplication.java b/service-pulsar-query/src/main/java/com/lanyuanxiaoyao/service/pulsar/PulsarQueryApplication.java index 33c6a99..60e6dc8 100644 --- a/service-pulsar-query/src/main/java/com/lanyuanxiaoyao/service/pulsar/PulsarQueryApplication.java +++ b/service-pulsar-query/src/main/java/com/lanyuanxiaoyao/service/pulsar/PulsarQueryApplication.java @@ -273,7 +273,7 @@ public class PulsarQueryApplication { .build()) { Map 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; }