[pulsar] branch branch-3.0 updated: [improve][cli] Allow pulser-client consume create a replicated subscription (#20316)

[technoboy]

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

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


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 712d80190ab [improve][cli] Allow pulser-client consume create a 
replicated subscription (#20316)
712d80190ab is described below

commit 712d80190ab319f3912da8e4647ad952e2ccfd3d
Author: Kim, Joo Hyuk <beansk...@gmail.com>
AuthorDate: Fri May 19 00:21:37 2023 +0900

    [improve][cli] Allow pulser-client consume create a replicated subscription 
(#20316)
---
 .../src/main/java/org/apache/pulsar/client/cli/CmdConsume.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
index 58ab6360a17..0c65604cbe6 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
@@ -109,6 +109,9 @@ public class CmdConsume extends AbstractCmdConsume {
     @Parameter(names = { "-pm", "--pool-messages" }, description = "Use the 
pooled message", arity = 1)
     private boolean poolMessages = true;
 
+    @Parameter(names = {"-rs", "--replicated" }, description = "Whether the 
subscription status should be replicated")
+    private boolean replicateSubscriptionState = false;
+
     public CmdConsume() {
         // Do nothing
         super();
@@ -156,7 +159,8 @@ public class CmdConsume extends AbstractCmdConsume {
                     .subscriptionType(subscriptionType)
                     .subscriptionMode(subscriptionMode)
                     .subscriptionInitialPosition(subscriptionInitialPosition)
-                    .poolMessages(poolMessages);
+                    .poolMessages(poolMessages)
+                    .replicateSubscriptionState(replicateSubscriptionState);
 
             if (isRegex) {
                 builder.topicsPattern(Pattern.compile(topic));