diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java index fd169fe1d1d596..d41869a97a58e8 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java @@ -873,12 +873,16 @@ public synchronized PulsarClient getClient() throws PulsarServerException { ClientBuilder builder = PulsarClient.builder() .serviceUrl(this.getConfiguration().isTlsEnabled() ? this.brokerServiceUrlTls : this.brokerServiceUrl) - .enableTls(this.getConfiguration().isTlsEnabled()) - .allowTlsInsecureConnection(this.getConfiguration().isTlsAllowInsecureConnection()) - .tlsTrustCertsFilePath(this.getConfiguration().getTlsCertificateFilePath()); + .enableTls(this.getConfiguration().isTlsEnabled()); + + if (this.getConfiguration().isBrokerClientTlsEnabled()) { + builder.allowTlsInsecureConnection(this.getConfiguration().isTlsAllowInsecureConnection()); + builder.tlsTrustCertsFilePath(this.getConfiguration().getBrokerClientTrustCertsFilePath()); + } + if (isNotBlank(this.getConfiguration().getBrokerClientAuthenticationPlugin())) { builder.authentication(this.getConfiguration().getBrokerClientAuthenticationPlugin(), - this.getConfiguration().getBrokerClientAuthenticationParameters()); + this.getConfiguration().getBrokerClientAuthenticationParameters()); } this.client = builder.build(); } catch (Exception e) {