[fix] [admin] Fix lookup get a null result if uses proxy (apache#23556)

(cherry picked from commit c53a85e) (cherry picked from commit 2b98d2d)
datastax · Nov 5, 2024 · 9a2d6ee · 9a2d6ee
1 parent 88301af
commit 9a2d6ee
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/LookupImpl.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/LookupImpl.java
@@ -24,6 +24,7 @@
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
 import javax.ws.rs.client.WebTarget;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.pulsar.client.admin.Lookup;
 import org.apache.pulsar.client.admin.PulsarAdminException;
 import org.apache.pulsar.client.admin.Topics;
@@ -57,7 +58,8 @@ public CompletableFuture<String> lookupTopicAsync(String topic) {
         WebTarget path = v2lookup.path(prefix).path(topicName.getLookupName());
 
         return asyncGetRequest(path, new FutureCallback<LookupData>() {})
-                .thenApply(lookupData -> useTls ? lookupData.getBrokerUrlTls() : lookupData.getBrokerUrl());
+                .thenApply(lookupData -> useTls && StringUtils.isNotBlank(lookupData.getBrokerUrlTls())
+                        ? lookupData.getBrokerUrlTls() : lookupData.getBrokerUrl());
     }
 
     @Override