You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by je...@apache.org on 2019/06/11 18:15:15 UTC
[pulsar] branch master updated: Add function worker client auth
config in cluster. (#4499)
This is an automated email from the ASF dual-hosted git repository.
jerrypeng 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 a52e9af Add function worker client auth config in cluster. (#4499)
a52e9af is described below
commit a52e9af9ddfeb90c129a77969c60f6da38281e9d
Author: Fangbin Sun <su...@gmail.com>
AuthorDate: Wed Jun 12 02:15:07 2019 +0800
Add function worker client auth config in cluster. (#4499)
---
.../src/main/java/org/apache/pulsar/PulsarBrokerStarter.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java
index 4502ea2..19570f5 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java
@@ -188,6 +188,16 @@ public class PulsarBrokerStarter {
workerConfig.setZooKeeperSessionTimeoutMillis(brokerConfig.getZooKeeperSessionTimeoutMillis());
workerConfig.setZooKeeperOperationTimeoutSeconds(brokerConfig.getZooKeeperOperationTimeoutSeconds());
+ workerConfig.setUseTls(brokerConfig.isTlsEnabled());
+ workerConfig.setTlsHostnameVerificationEnable(false);
+
+ workerConfig.setTlsAllowInsecureConnection(brokerConfig.isTlsAllowInsecureConnection());
+ workerConfig.setTlsTrustCertsFilePath(brokerConfig.getTlsTrustCertsFilePath());
+
+ // client in worker will use this config to authenticate with broker
+ workerConfig.setClientAuthenticationPlugin(brokerConfig.getBrokerClientAuthenticationPlugin());
+ workerConfig.setClientAuthenticationParameters(brokerConfig.getBrokerClientAuthenticationParameters());
+
// inherit super users
workerConfig.setSuperUserRoles(brokerConfig.getSuperUserRoles());