From b7bdd25bdcace161702b9197f79584b29e70b72d Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Mon, 22 Jan 2024 16:44:33 +0800 Subject: [PATCH] =?UTF-8?q?fix(pulsar-query):=20=E4=BF=AE=E5=A4=8Dpulsar?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2topic=E5=AD=98=E5=9C=A8=E6=B2=A1=E6=9C=89?= =?UTF-8?q?=E4=BD=BF=E7=94=A8admin=20url?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/pulsar/PulsarQueryApplication.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) 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 0b88e2c..e7730b8 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 @@ -20,6 +20,8 @@ import org.apache.pulsar.common.policies.data.*; import org.eclipse.collections.api.factory.Lists; import org.eclipse.collections.api.list.ImmutableList; import org.eclipse.collections.api.list.MutableList; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.gson.GsonAutoConfiguration; @@ -51,6 +53,8 @@ import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("pulsar") public class PulsarQueryApplication { + private static final Logger logger = LoggerFactory.getLogger(PulsarQueryApplication.class); + public static void main(String[] args) { SpringApplication.run(PulsarQueryApplication.class, args); } @@ -276,8 +280,11 @@ public class PulsarQueryApplication { @Cacheable(value = "exists-topic", sync = true) @GetMapping("exists_topic") public Boolean existsTopic(@RequestParam("url") String url, @RequestParam("topic") String topic) throws PulsarClientException, PulsarAdminException { + String name = name(url); + logger.info("Detected name: {}", name); + PulsarInfo info = getInfo(name); try (PulsarAdmin admin = PulsarAdmin.builder() - .serviceHttpUrl(url) + .serviceHttpUrl(adminUrl(info)) .build()) { List tenants = admin.tenants().getTenants(); for (String tenant : tenants) {