Repository: incubator-ranger Updated Branches: refs/heads/master 5a4e1a31e -> 2de668a2d
Update Ranger to use Kafka version 0.10.0.0 (from 0.9.0.0) Signed-off-by: rmani <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/2de668a2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/2de668a2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/2de668a2 Branch: refs/heads/master Commit: 2de668a2d158913beb509b5c4432c1475880277a Parents: 5a4e1a3 Author: Madhan Neethiraj <[email protected]> Authored: Thu Jun 9 14:48:23 2016 -0700 Committer: rmani <[email protected]> Committed: Mon Jun 13 21:37:47 2016 -0700 ---------------------------------------------------------------------- .../authorization/kafka/authorizer/RangerKafkaAuthorizer.java | 4 ++-- pom.xml | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/2de668a2/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java ---------------------------------------------------------------------- diff --git a/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java b/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java index 59bac13..1afedd5 100644 --- a/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java +++ b/plugin-kafka/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java @@ -34,7 +34,7 @@ import org.apache.commons.lang.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.security.UserGroupInformation; -import org.apache.kafka.common.security.kerberos.LoginManager; +import org.apache.kafka.common.security.authenticator.LoginManager; import org.apache.ranger.audit.provider.MiscUtil; import org.apache.ranger.plugin.audit.RangerDefaultAuditHandler; import org.apache.ranger.plugin.policyengine.RangerAccessRequestImpl; @@ -77,7 +77,7 @@ public class RangerKafkaAuthorizer implements Authorizer { public void configure(Map<String, ?> configs) { if (rangerPlugin == null) { try { - LoginManager loginManager = LoginManager.acquireLoginManager(LoginType.SERVER, configs); + LoginManager loginManager = LoginManager.acquireLoginManager(LoginType.SERVER, true, configs); Subject subject = loginManager.subject(); UserGroupInformation ugi = MiscUtil .createUGIFromSubject(subject); http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/2de668a2/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 9fe2753..9f04e96 100644 --- a/pom.xml +++ b/pom.xml @@ -186,7 +186,7 @@ <json.version>3.2.11</json.version> <jsr305.version>1.3.9</jsr305.version> <junit.version>4.12</junit.version> - <kafka.version>0.9.0.0</kafka.version> + <kafka.version>0.10.0.0</kafka.version> <knox.gateway.version>0.6.0</knox.gateway.version> <local.lib.dir>${project.basedir}/../lib/local</local.lib.dir> <log4j.version>1.2.17</log4j.version>
