This is an automated email from the ASF dual-hosted git repository.
liuyu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new d584d88c6af [doc][feat] use replicationClusters instead of
setReplicationClusters
d584d88c6af is described below
commit d584d88c6af11425e1b80a13e921604f18d07cde
Author: sunheyi <[email protected]>
AuthorDate: Tue Jul 18 15:21:28 2023 +0800
[doc][feat] use replicationClusters instead of setReplicationClusters
---
docs/administration-geo.md | 4 ++--
versioned_docs/version-2.10.x/administration-geo.md | 4 ++--
versioned_docs/version-2.11.x/administration-geo.md | 4 ++--
versioned_docs/version-2.2.0/administration-geo.md | 4 ++--
versioned_docs/version-2.2.1/administration-geo.md | 4 ++--
versioned_docs/version-2.3.0/administration-geo.md | 4 ++--
versioned_docs/version-2.3.1/administration-geo.md | 4 ++--
versioned_docs/version-2.3.2/administration-geo.md | 4 ++--
versioned_docs/version-2.4.0/administration-geo.md | 6 +++---
versioned_docs/version-2.4.1/administration-geo.md | 6 +++---
versioned_docs/version-2.4.2/administration-geo.md | 6 +++---
versioned_docs/version-2.5.0/administration-geo.md | 4 ++--
versioned_docs/version-2.5.1/administration-geo.md | 4 ++--
versioned_docs/version-2.5.2/administration-geo.md | 4 ++--
versioned_docs/version-2.6.0/administration-geo.md | 4 ++--
versioned_docs/version-2.6.1/administration-geo.md | 4 ++--
versioned_docs/version-2.6.2/administration-geo.md | 4 ++--
versioned_docs/version-2.6.3/administration-geo.md | 4 ++--
versioned_docs/version-2.6.4/administration-geo.md | 6 +++---
versioned_docs/version-2.7.0/administration-geo.md | 4 ++--
versioned_docs/version-2.7.1/administration-geo.md | 4 ++--
versioned_docs/version-2.7.2/administration-geo.md | 4 ++--
versioned_docs/version-2.7.3/administration-geo.md | 4 ++--
versioned_docs/version-2.7.4/administration-geo.md | 4 ++--
versioned_docs/version-2.7.5/administration-geo.md | 4 ++--
versioned_docs/version-2.8.x/administration-geo.md | 4 ++--
versioned_docs/version-2.9.x/administration-geo.md | 4 ++--
versioned_docs/version-3.0.x/administration-geo.md | 4 ++--
28 files changed, 60 insertions(+), 60 deletions(-)
diff --git a/docs/administration-geo.md b/docs/administration-geo.md
index cedf535b4fe..8f3cd0aa31c 100644
--- a/docs/administration-geo.md
+++ b/docs/administration-geo.md
@@ -146,7 +146,7 @@ topicLevelPoliciesEnabled=true
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example of the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
+The following is an example of the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
```java
List<String> restrictReplicationTo = Arrays.asList(
@@ -160,7 +160,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.10.x/administration-geo.md
b/versioned_docs/version-2.10.x/administration-geo.md
index 316f253f26f..b67291ed4ef 100644
--- a/versioned_docs/version-2.10.x/administration-geo.md
+++ b/versioned_docs/version-2.10.x/administration-geo.md
@@ -157,7 +157,7 @@ topicLevelPoliciesEnabled=true
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
```java
@@ -172,7 +172,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.11.x/administration-geo.md
b/versioned_docs/version-2.11.x/administration-geo.md
index 2496ca00522..eeebca307fd 100644
--- a/versioned_docs/version-2.11.x/administration-geo.md
+++ b/versioned_docs/version-2.11.x/administration-geo.md
@@ -146,7 +146,7 @@ topicLevelPoliciesEnabled=true
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example of the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
+The following is an example of the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
```java
List<String> restrictReplicationTo = Arrays.asList(
@@ -160,7 +160,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.2.0/administration-geo.md
b/versioned_docs/version-2.2.0/administration-geo.md
index 543103488d2..ff0ec7c9bfa 100644
--- a/versioned_docs/version-2.2.0/administration-geo.md
+++ b/versioned_docs/version-2.2.0/administration-geo.md
@@ -135,7 +135,7 @@ $ bin/pulsar-admin namespaces set-clusters
my-tenant/my-namespace \
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.2.1/administration-geo.md
b/versioned_docs/version-2.2.1/administration-geo.md
index 543103488d2..ff0ec7c9bfa 100644
--- a/versioned_docs/version-2.2.1/administration-geo.md
+++ b/versioned_docs/version-2.2.1/administration-geo.md
@@ -135,7 +135,7 @@ $ bin/pulsar-admin namespaces set-clusters
my-tenant/my-namespace \
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.3.0/administration-geo.md
b/versioned_docs/version-2.3.0/administration-geo.md
index 543103488d2..ff0ec7c9bfa 100644
--- a/versioned_docs/version-2.3.0/administration-geo.md
+++ b/versioned_docs/version-2.3.0/administration-geo.md
@@ -135,7 +135,7 @@ $ bin/pulsar-admin namespaces set-clusters
my-tenant/my-namespace \
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.3.1/administration-geo.md
b/versioned_docs/version-2.3.1/administration-geo.md
index 543103488d2..ff0ec7c9bfa 100644
--- a/versioned_docs/version-2.3.1/administration-geo.md
+++ b/versioned_docs/version-2.3.1/administration-geo.md
@@ -135,7 +135,7 @@ $ bin/pulsar-admin namespaces set-clusters
my-tenant/my-namespace \
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.3.2/administration-geo.md
b/versioned_docs/version-2.3.2/administration-geo.md
index 099510d8437..b78a4c43e4b 100644
--- a/versioned_docs/version-2.3.2/administration-geo.md
+++ b/versioned_docs/version-2.3.2/administration-geo.md
@@ -92,7 +92,7 @@ Once you've created a geo-replication namespace, any topics
that producers or co
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message will be replicated only to the subset
in the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -107,7 +107,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.4.0/administration-geo.md
b/versioned_docs/version-2.4.0/administration-geo.md
index 10dec4fe2ed..d811d5a22e8 100644
--- a/versioned_docs/version-2.4.0/administration-geo.md
+++ b/versioned_docs/version-2.4.0/administration-geo.md
@@ -91,7 +91,7 @@ Once you've created a geo-replication namespace, any topics
that producers or co
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message will be replicated only to the subset
in the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -106,7 +106,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
@@ -167,4 +167,4 @@ Consumer<String> consumer =
client.newConsumer(Schema.STRING)
### Limitations
* When you enable replicated subscription, you're creating a consistent
distributed snapshot to establish an association between message ids from
different clusters. The snapshots are taken periodically. The default value is
`1 second`. It means that a consumer failing over to a different cluster can
potentially receive 1 second of duplicates. You can also configure the
frequency of the snapshot in the `broker.conf` file.
-* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
\ No newline at end of file
+* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
diff --git a/versioned_docs/version-2.4.1/administration-geo.md
b/versioned_docs/version-2.4.1/administration-geo.md
index 10dec4fe2ed..d811d5a22e8 100644
--- a/versioned_docs/version-2.4.1/administration-geo.md
+++ b/versioned_docs/version-2.4.1/administration-geo.md
@@ -91,7 +91,7 @@ Once you've created a geo-replication namespace, any topics
that producers or co
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message will be replicated only to the subset
in the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -106,7 +106,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
@@ -167,4 +167,4 @@ Consumer<String> consumer =
client.newConsumer(Schema.STRING)
### Limitations
* When you enable replicated subscription, you're creating a consistent
distributed snapshot to establish an association between message ids from
different clusters. The snapshots are taken periodically. The default value is
`1 second`. It means that a consumer failing over to a different cluster can
potentially receive 1 second of duplicates. You can also configure the
frequency of the snapshot in the `broker.conf` file.
-* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
\ No newline at end of file
+* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
diff --git a/versioned_docs/version-2.4.2/administration-geo.md
b/versioned_docs/version-2.4.2/administration-geo.md
index 44b2e577805..a15b9d08654 100644
--- a/versioned_docs/version-2.4.2/administration-geo.md
+++ b/versioned_docs/version-2.4.2/administration-geo.md
@@ -91,7 +91,7 @@ Once you've created a geo-replication namespace, any topics
that producers or co
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message will be replicated only to the subset
in the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when constructing the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -106,7 +106,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
@@ -166,4 +166,4 @@ Consumer<String> consumer =
client.newConsumer(Schema.STRING)
### Limitations
* When you enable replicated subscription, you're creating a consistent
distributed snapshot to establish an association between message ids from
different clusters. The snapshots are taken periodically. The default value is
`1 second`. It means that a consumer failing over to a different cluster can
potentially receive 1 second of duplicates. You can also configure the
frequency of the snapshot in the `broker.conf` file.
-* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
\ No newline at end of file
+* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
diff --git a/versioned_docs/version-2.5.0/administration-geo.md
b/versioned_docs/version-2.5.0/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.5.0/administration-geo.md
+++ b/versioned_docs/version-2.5.0/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.5.1/administration-geo.md
b/versioned_docs/version-2.5.1/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.5.1/administration-geo.md
+++ b/versioned_docs/version-2.5.1/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.5.2/administration-geo.md
b/versioned_docs/version-2.5.2/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.5.2/administration-geo.md
+++ b/versioned_docs/version-2.5.2/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.6.0/administration-geo.md
b/versioned_docs/version-2.6.0/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.6.0/administration-geo.md
+++ b/versioned_docs/version-2.6.0/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.6.1/administration-geo.md
b/versioned_docs/version-2.6.1/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.6.1/administration-geo.md
+++ b/versioned_docs/version-2.6.1/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.6.2/administration-geo.md
b/versioned_docs/version-2.6.2/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.6.2/administration-geo.md
+++ b/versioned_docs/version-2.6.2/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.6.3/administration-geo.md
b/versioned_docs/version-2.6.3/administration-geo.md
index 3896453e3bc..41e44668f8f 100644
--- a/versioned_docs/version-2.6.3/administration-geo.md
+++ b/versioned_docs/version-2.6.3/administration-geo.md
@@ -135,7 +135,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -150,7 +150,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.6.4/administration-geo.md
b/versioned_docs/version-2.6.4/administration-geo.md
index ebae39b8ca3..cc66c285b58 100644
--- a/versioned_docs/version-2.6.4/administration-geo.md
+++ b/versioned_docs/version-2.6.4/administration-geo.md
@@ -91,7 +91,7 @@ Once you create a geo-replication namespace, any topics that
producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -106,7 +106,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
@@ -167,4 +167,4 @@ Consumer<String> consumer =
client.newConsumer(Schema.STRING)
### Limitations
* When you enable replicated subscription, you're creating a consistent
distributed snapshot to establish an association between message ids from
different clusters. The snapshots are taken periodically. The default value is
`1 second`. It means that a consumer failing over to a different cluster can
potentially receive 1 second of duplicates. You can also configure the
frequency of the snapshot in the `broker.conf` file.
-* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
\ No newline at end of file
+* Only the base line cursor position is synced in replicated subscriptions
while the individual acknowledgments are not synced. This means the messages
acknowledged out-of-order could end up getting delivered again, in the case of
a cluster failover.
diff --git a/versioned_docs/version-2.7.0/administration-geo.md
b/versioned_docs/version-2.7.0/administration-geo.md
index 56cd22f4366..c8fbc2cebbe 100644
--- a/versioned_docs/version-2.7.0/administration-geo.md
+++ b/versioned_docs/version-2.7.0/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.7.1/administration-geo.md
b/versioned_docs/version-2.7.1/administration-geo.md
index 56cd22f4366..c8fbc2cebbe 100644
--- a/versioned_docs/version-2.7.1/administration-geo.md
+++ b/versioned_docs/version-2.7.1/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.7.2/administration-geo.md
b/versioned_docs/version-2.7.2/administration-geo.md
index 56cd22f4366..c8fbc2cebbe 100644
--- a/versioned_docs/version-2.7.2/administration-geo.md
+++ b/versioned_docs/version-2.7.2/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.7.3/administration-geo.md
b/versioned_docs/version-2.7.3/administration-geo.md
index 56cd22f4366..c8fbc2cebbe 100644
--- a/versioned_docs/version-2.7.3/administration-geo.md
+++ b/versioned_docs/version-2.7.3/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.7.4/administration-geo.md
b/versioned_docs/version-2.7.4/administration-geo.md
index 56cd22f4366..c8fbc2cebbe 100644
--- a/versioned_docs/version-2.7.4/administration-geo.md
+++ b/versioned_docs/version-2.7.4/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.7.5/administration-geo.md
b/versioned_docs/version-2.7.5/administration-geo.md
index 56cd22f4366..c8fbc2cebbe 100644
--- a/versioned_docs/version-2.7.5/administration-geo.md
+++ b/versioned_docs/version-2.7.5/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the {@inject:
javadoc:Message:/client/org/apache/pulsar/client/api/Message} object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.8.x/administration-geo.md
b/versioned_docs/version-2.8.x/administration-geo.md
index 144b6ac397a..371479c6f67 100644
--- a/versioned_docs/version-2.8.x/administration-geo.md
+++ b/versioned_docs/version-2.8.x/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-2.9.x/administration-geo.md
b/versioned_docs/version-2.9.x/administration-geo.md
index 6f46e732e14..794c62643f5 100644
--- a/versioned_docs/version-2.9.x/administration-geo.md
+++ b/versioned_docs/version-2.9.x/administration-geo.md
@@ -136,7 +136,7 @@ Once you create a geo-replication namespace, any topics
that producers or consum
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
+The following is an example for the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
```java
@@ -151,7 +151,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
diff --git a/versioned_docs/version-3.0.x/administration-geo.md
b/versioned_docs/version-3.0.x/administration-geo.md
index 48344aa041f..9be134cf196 100644
--- a/versioned_docs/version-3.0.x/administration-geo.md
+++ b/versioned_docs/version-3.0.x/administration-geo.md
@@ -146,7 +146,7 @@ topicLevelPoliciesEnabled=true
By default, messages are replicated to all clusters configured for the
namespace. You can restrict replication selectively by specifying a replication
list for a message, and then that message is replicated only to the subset in
the replication list.
-The following is an example of the [Java API](client-libraries-java.md). Note
the use of the `setReplicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
+The following is an example of the [Java API](client-libraries-java.md). Note
the use of the `replicationClusters` method when you construct the
[Message](/api/client/org/apache/pulsar/client/api/Message) object:
```java
List<String> restrictReplicationTo = Arrays.asList(
@@ -160,7 +160,7 @@ Producer producer = client.newProducer()
producer.newMessage()
.value("my-payload".getBytes())
- .setReplicationClusters(restrictReplicationTo)
+ .replicationClusters(restrictReplicationTo)
.send();
```
