RANGER-246 Review feedback and allow kafka consumer groups Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/e3bc6613 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/e3bc6613 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/e3bc6613
Branch: refs/heads/tag-policy Commit: e3bc6613e778219fa182ebba2007f762a52f8930 Parents: 94cf87d Author: Don Bosco Durai <[email protected]> Authored: Sat Jun 6 19:31:44 2015 -0700 Committer: Don Bosco Durai <[email protected]> Committed: Sat Jun 6 19:31:44 2015 -0700 ---------------------------------------------------------------------- .../authorization/kafka/authorizer/RangerKafkaAuthorizer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/e3bc6613/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 9ce38a9..3341f84 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 @@ -137,7 +137,7 @@ public class RangerKafkaAuthorizer implements Authorizer { } //TODO: If resource type if consumer group, then allow it by default - if(resource.resourceType().equals(ResourceType.CLUSTER)) { + if(resource.resourceType().equals(ResourceType.CONSUMER_GROUP)) { return true; }
