From 240cef07c494442ea07a2fa614fdd28b8f4bb32a Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Mon, 6 May 2024 15:16:48 +0800 Subject: [PATCH] =?UTF-8?q?refactor(pulsar-query):=20=E4=BD=BFbacklog?= =?UTF-8?q?=E8=BF=94=E5=9B=9E=E9=BB=98=E8=AE=A4=E5=80=BC-1=20=E6=96=B9?= =?UTF-8?q?=E4=BE=BF=E5=90=8E=E7=BB=AD=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/pulsar/PulsarQueryApplication.java | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) 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)