diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java index b68a1d8fc04fcdda6b0da540cc4533d2b8f67a0a..a2c5e7240c3481062db053706e0396742bc5e1a5 100644 --- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java +++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java @@ -49,8 +49,10 @@ public class PulsarAdminTool { @Parameter(names = { "--tls-allow-insecure" }, description = "Allow TLS insecure connection") Boolean tlsAllowInsecureConnection; - - + + @Parameter(names = { "--tls-trust-cert-path" }, description = "Allow TLS trust cert file path") + String tlsTrustCertsFilePath; + @Parameter(names = { "--tls-enable-hostname-verification" }, description = "Enable TLS common name verification") Boolean tlsEnableHostnameVerification; @@ -70,7 +72,9 @@ public class PulsarAdminTool { boolean tlsEnableHostnameVerification = this.tlsEnableHostnameVerification != null ? this.tlsEnableHostnameVerification : Boolean.parseBoolean(properties.getProperty("tlsEnableHostnameVerification", "false")); - String tlsTrustCertsFilePath = properties.getProperty("tlsTrustCertsFilePath"); + final String tlsTrustCertsFilePath = StringUtils.isNotBlank(this.tlsTrustCertsFilePath) + ? this.tlsTrustCertsFilePath + : properties.getProperty("tlsTrustCertsFilePath"); adminBuilder = PulsarAdmin.builder().allowTlsInsecureConnection(tlsAllowInsecureConnection) .enableTlsHostnameVerification(tlsEnableHostnameVerification)