ranger-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rm...@apache.org
Subject incubator-ranger git commit: Update Ranger to use Kafka version 0.10.0.0 (from 0.9.0.0)
Date Tue, 14 Jun 2016 04:50:09 GMT
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 <rmani@hortonworks.com>


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 <madhan@apache.org>
Authored: Thu Jun 9 14:48:23 2016 -0700
Committer: rmani <rmani@hortonworks.com>
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>


Mime
View raw message