From 8e47ed43d3713af2a8148079e1e67335c8ce44d4 Mon Sep 17 00:00:00 2001
From: Baodi Shi <baodi@apache.org>
Date: Tue, 2 Jul 2024 20:17:40 +0800
Subject: [PATCH] Just use tlsUrl when brokerClientTlsEnable

---
 .../apache/pulsar/broker/namespace/NamespaceService.java | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java
index 2d7ee65badc04..2a1584df961f7 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java
@@ -1472,8 +1472,13 @@ public CompletableFuture<Boolean> checkNonPersistentNonPartitionedTopicExists(St
                                 "No broker was available to own " + topicName));
                     }
                     LookupData lookupData = lookupResult.get().getLookupData();
-                    String brokerUrl = StringUtils.isNotEmpty(lookupData.getBrokerUrlTls())
-                                                   ? lookupData.getBrokerUrlTls() : lookupData.getBrokerUrl();
+                    String brokerUrl;
+                    if (pulsar.getConfiguration().isBrokerClientTlsEnabled()
+                            && StringUtils.isNotEmpty(lookupData.getBrokerUrlTls())) {
+                        brokerUrl = lookupData.getBrokerUrlTls();
+                    } else {
+                        brokerUrl = lookupData.getBrokerUrl();
+                    }
                     return pulsarClient.getLookup(brokerUrl)
                         .getPartitionedTopicMetadata(topicName, false)
                         .thenApply(metadata -> true)