[improve][cli] Expose updateLocalTopicOnly to UpdatePartitionedCmd
@@ -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);
}
}
