(pulsar) branch branch-3.3 updated: [fix] Initialize UrlServiceProvider before trying to use transaction coordinator (#23914)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.3 by this push:
     new a7c8ab98118 [fix] Initialize UrlServiceProvider before trying to use 
transaction coordinator (#23914)
a7c8ab98118 is described below

commit a7c8ab9811808d55d08079f7e1fad7a51f657b52
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Thu Jan 30 18:23:37 2025 -0800

    [fix] Initialize UrlServiceProvider before trying to use transaction 
coordinator (#23914)
    
    (cherry picked from commit cdab2d6dc4b620bdf129b05882b5f3bf4925ff61)
---
 .../main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java  | 6 +-----
 .../main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java   | 4 ++++
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
index 8cc1568122b..255a381a31c 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
@@ -67,11 +67,7 @@ public class ClientBuilderImpl implements ClientBuilder {
         if (conf.getAuthentication() == null || conf.getAuthentication() == 
AuthenticationDisabled.INSTANCE) {
             setAuthenticationFromPropsIfAvailable(conf);
         }
-        PulsarClient client = new PulsarClientImpl(conf);
-        if (conf.getServiceUrlProvider() != null) {
-            conf.getServiceUrlProvider().initialize(client);
-        }
-        return client;
+        return new PulsarClientImpl(conf);
     }
 
     @Override
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
index 26a27caf0cf..2a052b8024b 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
@@ -244,6 +244,10 @@ public class PulsarClientImpl implements PulsarClient {
                 this.timer = timer;
             }
 
+            if (conf.getServiceUrlProvider() != null) {
+                conf.getServiceUrlProvider().initialize(this);
+            }
+
             if (conf.isEnableTransaction()) {
                 tcClient = new TransactionCoordinatorClientImpl(this);
                 try {