You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ranger.apache.org by rm...@apache.org on 2017/06/16 23:49:51 UTC
ranger git commit: RANGER-1648 : Ranger Kafka Plugin now should use
the Short name from Kafka Session Object
Repository: ranger
Updated Branches:
refs/heads/master a94de1104 -> fdd1d294c
RANGER-1648 : Ranger Kafka Plugin now should use the Short name from Kafka Session Object
Project: http://git-wip-us.apache.org/repos/asf/ranger/repo
Commit: http://git-wip-us.apache.org/repos/asf/ranger/commit/fdd1d294
Tree: http://git-wip-us.apache.org/repos/asf/ranger/tree/fdd1d294
Diff: http://git-wip-us.apache.org/repos/asf/ranger/diff/fdd1d294
Branch: refs/heads/master
Commit: fdd1d294c6b3c0e3cd8dd4219d034ad63210b380
Parents: a94de11
Author: rmani <rm...@hortonworks.com>
Authored: Fri Jun 16 16:26:52 2017 -0700
Committer: rmani <rm...@hortonworks.com>
Committed: Fri Jun 16 16:26:52 2017 -0700
----------------------------------------------------------------------
.../authorization/kafka/authorizer/RangerKafkaAuthorizer.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ranger/blob/fdd1d294/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 ec7f887..b6e052f 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
@@ -133,8 +133,6 @@ public class RangerKafkaAuthorizer implements Authorizer {
String userName = null;
if (session.principal() != null) {
userName = session.principal().getName();
- userName = StringUtils.substringBefore(userName, "/");
- userName = StringUtils.substringBefore(userName, "@");
}
java.util.Set<String> userGroups = MiscUtil
.getGroupsForRequestUser(userName);