Make athenzConf and athenzPrincipalHeader configurable (apache#661)

yew1eb · Aug 9, 2017 · 005aa12 · 005aa12
1 parent b0ee661
commit 005aa12
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...nt-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java b/...nt-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java
@@ -90,6 +90,12 @@ public void configure(Map<String, String> authParams) {
         this.providerDomain = authParams.get("providerDomain");
         this.privateKeyPath = authParams.get("privateKeyPath");
         this.keyId = authParams.getOrDefault("keyId", "0");
+        if (authParams.containsKey("athenzConfPath")) {
+            System.setProperty("athenz.athenz_conf", authParams.get("athenzConfPath"));
+        }
+        if (authParams.containsKey("principalHeader")) {
+            System.setProperty("athenz.auth.principal.header", authParams.get("principalHeader"));
+        }
     }
 
     @Override