Repository: incubator-ranger Updated Branches: refs/heads/ranger-0.6 351f870df -> bf7188031
RANGER-1171 - Invert authorization logic in RangerKafkaAuthorizer Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/bf718803 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/bf718803 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/bf718803 Branch: refs/heads/ranger-0.6 Commit: bf7188031c715196a3e9a7f3f23c700d2deb427c Parents: 351f870 Author: Colm O hEigeartaigh <[email protected]> Authored: Thu Sep 8 11:50:21 2016 +0100 Committer: Colm O hEigeartaigh <[email protected]> Committed: Fri Sep 9 09:55:59 2016 +0100 ---------------------------------------------------------------------- .../authorization/kafka/authorizer/RangerKafkaAuthorizer.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/bf718803/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 452698b..96eed9d 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 @@ -62,8 +62,6 @@ public class RangerKafkaAuthorizer implements Authorizer { public static final String ACCESS_TYPE_KAFKA_ADMIN = "kafka_admin"; private static volatile RangerBasePlugin rangerPlugin = null; - long lastLogTime = 0; - int errorLogFreq = 30000; // Log after every 30 seconds public RangerKafkaAuthorizer() { } @@ -187,11 +185,10 @@ public class RangerKafkaAuthorizer implements Authorizer { validationFailed = true; } - boolean returnValue = true; + boolean returnValue = false; if (validationFailed) { MiscUtil.logErrorMessageByInterval(logger, validationStr + ", request=" + rangerRequest); - returnValue = false; } else { try { @@ -199,7 +196,6 @@ public class RangerKafkaAuthorizer implements Authorizer { .isAccessAllowed(rangerRequest); if (result == null) { logger.error("Ranger Plugin returned null. Returning false"); - returnValue = false; } else { returnValue = result.getIsAllowed(); }
