Added the required serviceUrlProvider method for building PulsarClient. (#891)
diff --git a/docs/client-libraries-cluster-level-failover.md b/docs/client-libraries-cluster-level-failover.md
index f63cddc..754362a 100644
--- a/docs/client-libraries-cluster-level-failover.md
+++ b/docs/client-libraries-cluster-level-failover.md
@@ -66,7 +66,8 @@
.build();
PulsarClient pulsarClient = PulsarClient.builder()
- .authentication(primaryAuthentication)
+ .serviceUrlProvider(failover)
+ .authentication(primaryAuthentication)
.tlsTrustCertsFilePath(primaryTlsTrustCertsFilePath)
.build();
@@ -113,6 +114,7 @@
PulsarClient pulsarClient =
PulsarClient.builder()
+ .serviceUrlProvider(provider)
.build();
provider.initialize(pulsarClient);
@@ -155,4 +157,4 @@
}
```
-3. Pulsar client 1 connects to cluster A using credential *c1*.
\ No newline at end of file
+3. Pulsar client 1 connects to cluster A using credential *c1*.
diff --git a/versioned_docs/version-2.10.x/client-libraries-java.md b/versioned_docs/version-2.10.x/client-libraries-java.md
index 6b5e81b..0027a6b 100644
--- a/versioned_docs/version-2.10.x/client-libraries-java.md
+++ b/versioned_docs/version-2.10.x/client-libraries-java.md
@@ -376,7 +376,8 @@
.build();
PulsarClient pulsarClient = PulsarClient.builder()
- .authentication(primaryAuthentication)
+ .serviceUrlProvider(failover)
+ .authentication(primaryAuthentication)
.tlsTrustCertsFilePath(primaryTlsTrustCertsFilePath)
.build();
@@ -419,7 +420,9 @@
.urlProviderHeader(header)
.build();
- PulsarClient pulsarClient = PulsarClient.builder().build();
+ PulsarClient pulsarClient = PulsarClient.builder()
+ .serviceUrlProvider(provider)
+ .build();
provider.initialize(pulsarClient);
return pulsarClient;
diff --git a/versioned_docs/version-2.11.x/client-libraries-java.md b/versioned_docs/version-2.11.x/client-libraries-java.md
index d0b3637..8bc0753 100644
--- a/versioned_docs/version-2.11.x/client-libraries-java.md
+++ b/versioned_docs/version-2.11.x/client-libraries-java.md
@@ -1238,7 +1238,8 @@
.build();
PulsarClient pulsarClient = PulsarClient.builder()
- .authentication(primaryAuthentication)
+ .serviceUrlProvider(failover)
+ .authentication(primaryAuthentication)
.tlsTrustCertsFilePath(primaryTlsTrustCertsFilePath)
.build();
@@ -1281,7 +1282,9 @@
.urlProviderHeader(header)
.build();
- PulsarClient pulsarClient = PulsarClient.builder().build();
+ PulsarClient pulsarClient = PulsarClient.builder()
+ .serviceUrlProvider(provider)
+ .build();
provider.initialize(pulsarClient);
return pulsarClient;
diff --git a/versioned_docs/version-3.0.x/client-libraries-cluster-level-failover.md b/versioned_docs/version-3.0.x/client-libraries-cluster-level-failover.md
index e84acc4..2b3a8c9 100644
--- a/versioned_docs/version-3.0.x/client-libraries-cluster-level-failover.md
+++ b/versioned_docs/version-3.0.x/client-libraries-cluster-level-failover.md
@@ -65,7 +65,8 @@
.build();
PulsarClient pulsarClient = PulsarClient.builder()
- .authentication(primaryAuthentication)
+ .serviceUrlProvider(failover)
+ .authentication(primaryAuthentication)
.tlsTrustCertsFilePath(primaryTlsTrustCertsFilePath)
.build();
@@ -112,6 +113,7 @@
PulsarClient pulsarClient =
PulsarClient.builder()
+ .serviceUrlProvider(provider)
.build();
provider.initialize(pulsarClient);
@@ -154,4 +156,4 @@
}
```
-3. Pulsar client 1 connects to cluster A using credential *c1*.
\ No newline at end of file
+3. Pulsar client 1 connects to cluster A using credential *c1*.
diff --git a/versioned_docs/version-3.1.x/client-libraries-cluster-level-failover.md b/versioned_docs/version-3.1.x/client-libraries-cluster-level-failover.md
index e84acc4..2b3a8c9 100644
--- a/versioned_docs/version-3.1.x/client-libraries-cluster-level-failover.md
+++ b/versioned_docs/version-3.1.x/client-libraries-cluster-level-failover.md
@@ -65,7 +65,8 @@
.build();
PulsarClient pulsarClient = PulsarClient.builder()
- .authentication(primaryAuthentication)
+ .serviceUrlProvider(failover)
+ .authentication(primaryAuthentication)
.tlsTrustCertsFilePath(primaryTlsTrustCertsFilePath)
.build();
@@ -112,6 +113,7 @@
PulsarClient pulsarClient =
PulsarClient.builder()
+ .serviceUrlProvider(provider)
.build();
provider.initialize(pulsarClient);
@@ -154,4 +156,4 @@
}
```
-3. Pulsar client 1 connects to cluster A using credential *c1*.
\ No newline at end of file
+3. Pulsar client 1 connects to cluster A using credential *c1*.
diff --git a/versioned_docs/version-3.2.x/client-libraries-cluster-level-failover.md b/versioned_docs/version-3.2.x/client-libraries-cluster-level-failover.md
index f63cddc..754362a 100644
--- a/versioned_docs/version-3.2.x/client-libraries-cluster-level-failover.md
+++ b/versioned_docs/version-3.2.x/client-libraries-cluster-level-failover.md
@@ -66,7 +66,8 @@
.build();
PulsarClient pulsarClient = PulsarClient.builder()
- .authentication(primaryAuthentication)
+ .serviceUrlProvider(failover)
+ .authentication(primaryAuthentication)
.tlsTrustCertsFilePath(primaryTlsTrustCertsFilePath)
.build();
@@ -113,6 +114,7 @@
PulsarClient pulsarClient =
PulsarClient.builder()
+ .serviceUrlProvider(provider)
.build();
provider.initialize(pulsarClient);
@@ -155,4 +157,4 @@
}
```
-3. Pulsar client 1 connects to cluster A using credential *c1*.
\ No newline at end of file
+3. Pulsar client 1 connects to cluster A using credential *c1*.
