[pulsar] branch master updated: [pulsar-admin] Check validity of --compatibility for namespace (#12483)

[eolivelli]

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

eolivelli 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 030358e  [pulsar-admin] Check validity of --compatibility for 
namespace (#12483)
030358e is described below

commit 030358e515df20556a200cfe3f88286313d92be1
Author: Ruguo Yu <jiang7chengz...@163.com>
AuthorDate: Thu Oct 28 13:18:13 2021 +0800

    [pulsar-admin] Check validity of --compatibility for namespace (#12483)
---
 .../src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
index 50baa02..6ce9ae6 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
@@ -1845,7 +1845,14 @@ public class CmdNamespaces extends CmdBase {
             String namespace = validateNamespace(params);
 
             String strategyStr = strategyParam != null ? 
strategyParam.toUpperCase() : "";
-            getAdmin().namespaces().setSchemaCompatibilityStrategy(namespace, 
SchemaCompatibilityStrategy.valueOf(strategyStr));
+            SchemaCompatibilityStrategy strategy;
+            try {
+                strategy = SchemaCompatibilityStrategy.valueOf(strategyStr);
+            } catch (IllegalArgumentException exception) {
+                throw new ParameterException(String.format("Illegal schema 
compatibility strategy %s. " +
+                        "Possible values: %s", strategyStr, 
Arrays.toString(SchemaCompatibilityStrategy.values())));
+            }
+            getAdmin().namespaces().setSchemaCompatibilityStrategy(namespace, 
strategy);
         }
     }