Repository: incubator-ranger Updated Branches: refs/heads/ranger-0.5 e4a286e77 -> dbe192ca1
RANGER-744: Kafka Authorizer has updated how IP/Host is passed Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/dbe192ca Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/dbe192ca Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/dbe192ca Branch: refs/heads/ranger-0.5 Commit: dbe192ca18dfce6299020f68f8a0b3b19395b412 Parents: e4a286e Author: Don Bosco Durai <[email protected]> Authored: Tue Nov 24 23:24:53 2015 -0800 Committer: Don Bosco Durai <[email protected]> Committed: Tue Nov 24 23:24:53 2015 -0800 ---------------------------------------------------------------------- .../kafka/authorizer/RangerKafkaAuthorizer.java | 7 +------ .../kafka/authorizer/RangerKafkaAuthorizer.java | 22 +++++++++++++++++++- 2 files changed, 22 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/dbe192ca/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 29c2ceb..7ca12ce 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 @@ -101,11 +101,6 @@ public class RangerKafkaAuthorizer implements Authorizer { } } - /* - * (non-Javadoc) - * - * @see kafka.security.auth.Authorizer#configure(Map<String, Object>) - */ @Override public void close() { logger.info("close() called on authorizer."); @@ -141,7 +136,7 @@ public class RangerKafkaAuthorizer implements Authorizer { } java.util.Set<String> userGroups = MiscUtil .getGroupsForRequestUser(userName); - String ip = session.host(); + String ip = session.clientAddress().getHostAddress(); // skip leading slash if (StringUtils.isNotEmpty(ip) && ip.charAt(0) == '/') { http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/dbe192ca/ranger-kafka-plugin-shim/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java ---------------------------------------------------------------------- diff --git a/ranger-kafka-plugin-shim/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java b/ranger-kafka-plugin-shim/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java index 0937835..90b1ab0 100644 --- a/ranger-kafka-plugin-shim/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java +++ b/ranger-kafka-plugin-shim/src/main/java/org/apache/ranger/authorization/kafka/authorizer/RangerKafkaAuthorizer.java @@ -104,6 +104,26 @@ public class RangerKafkaAuthorizer implements Authorizer { } @Override + public void close() { + if(LOG.isDebugEnabled()) { + LOG.debug("==> RangerKafkaAuthorizer.close()"); + } + + try { + activatePluginClassLoader(); + + rangerKakfaAuthorizerImpl.close(); + } finally { + deactivatePluginClassLoader(); + } + + if(LOG.isDebugEnabled()) { + LOG.debug("<== RangerKafkaAuthorizer.close()"); + } + + } + + @Override public boolean authorize(Session session, Operation operation,Resource resource) { if(LOG.isDebugEnabled()) { LOG.debug("==> RangerKafkaAuthorizer.authorize(Session, Operation, Resource)"); @@ -268,4 +288,4 @@ public class RangerKafkaAuthorizer implements Authorizer { } } -} \ No newline at end of file +}
