[pulsar] branch master updated: [improve][cli] Expose updateLocalTopicOnly to UpdatePartitionedCmd (#19162)

[zixuan]

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

zixuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 9ef54fd012e [improve][cli] Expose updateLocalTopicOnly to 
UpdatePartitionedCmd (#19162)
9ef54fd012e is described below

commit 9ef54fd012e2f80f4499263f6ac4542b45c5bc15
Author: AloysZhang <lofterzh...@gmail.com>
AuthorDate: Tue Jan 10 15:07:29 2023 +0800

    [improve][cli] Expose updateLocalTopicOnly to UpdatePartitionedCmd (#19162)
---
 .../src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java        | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
index eb8bee3bb84..116252cca6d 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
@@ -594,6 +594,10 @@ public class CmdTopics extends CmdBase {
                 "--partitions" }, description = "Number of partitions for the 
topic", required = true)
         private int numPartitions;
 
+        @Parameter(names = { "-ulo",
+                "--update-local-only"}, description = "Update partitions 
number for topic in local cluster only")
+        private boolean updateLocalOnly = false;
+
         @Parameter(names = { "-f",
                 "--force" }, description = "Update forcefully without 
validating existing partitioned topic")
         private boolean force;
@@ -601,7 +605,7 @@ public class CmdTopics extends CmdBase {
         @Override
         void run() throws Exception {
             String topic = validateTopicName(params);
-            getTopics().updatePartitionedTopic(topic, numPartitions, false, 
force);
+            getTopics().updatePartitionedTopic(topic, numPartitions, 
updateLocalOnly, force);
         }
     }