Just use tlsUrl when brokerClientTlsEnable

apache · Jul 3, 2024 · 8e47ed4 · 8e47ed4
1 parent 633ae45
commit 8e47ed4
Showing 1 changed file with 7 additions and 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
@@ -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)