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 60e6dc8..2f373e5 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
@@ -15,10 +15,18 @@ import java.util.List;
 import java.util.Map;
 import org.apache.pulsar.client.admin.PulsarAdmin;
 import org.apache.pulsar.client.admin.PulsarAdminException;
-import org.apache.pulsar.client.api.*;
+import org.apache.pulsar.client.api.Consumer;
+import org.apache.pulsar.client.api.MessageId;
+import org.apache.pulsar.client.api.PulsarClient;
+import org.apache.pulsar.client.api.PulsarClientException;
+import org.apache.pulsar.client.api.SubscriptionMode;
+import org.apache.pulsar.client.api.SubscriptionType;
 import org.apache.pulsar.client.impl.schema.StringSchema;
 import org.apache.pulsar.common.policies.data.ConsumerStats;
-import org.apache.pulsar.common.policies.data.*;
+import org.apache.pulsar.common.policies.data.PublisherStats;
+import org.apache.pulsar.common.policies.data.ReplicatorStats;
+import org.apache.pulsar.common.policies.data.SubscriptionStats;
+import org.apache.pulsar.common.policies.data.TopicStats;
 import org.eclipse.collections.api.factory.Lists;
 import org.eclipse.collections.api.list.ImmutableList;
 import org.eclipse.collections.api.list.MutableList;
@@ -266,7 +274,7 @@ public class PulsarQueryApplication {
 
     @Cacheable(value = "backlog", sync = true)
     @GetMapping("backlog")
-    public Long backlog(@RequestParam("name") String name, @RequestParam("topic") String topic, @RequestParam("subscription") String subscription) throws PulsarClientException, PulsarAdminException {
+    public Long backlog(@RequestParam("name") String name, @RequestParam("topic") String topic, @RequestParam("subscription") String subscription) {
         PulsarInfo info = getInfo(name);
         try (PulsarAdmin admin = PulsarAdmin.builder()
                 .serviceHttpUrl(adminUrl(info))
@@ -275,8 +283,10 @@ public class PulsarQueryApplication {
             if (ObjectUtil.isNotNull(subscriptions) && subscriptions.containsKey(subscription)) {
                 return subscriptions.get(subscription).getMsgBacklog();
             }
-            return -1L;
+        } catch (PulsarClientException | PulsarAdminException e) {
+            logger.warn("Pulsar connect error", e);
         }
+        return -1L;
     }
 
     @Cacheable(value = "exists-topic", sync = true)