You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2021/10/28 05:20:10 UTC
[pulsar] branch master updated: [pulsar-admin] Check validity of
--compatibility for namespace (#12483)
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 <ji...@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);
}
}