RANGER-496 Fix build failure due to Kafka API change
Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/3c22cfa1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/3c22cfa1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/3c22cfa1 Branch: refs/heads/tag-policy Commit: 3c22cfa12b86e400bf8d6af4407010b9becd58fc Parents: b42dfb0 Author: Don Bosco Durai <[email protected]> Authored: Tue May 19 15:53:49 2015 -0700 Committer: Madhan Neethiraj <[email protected]> Committed: Thu May 21 15:50:16 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/3c22cfa1/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 4689957..655f1b9 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 @@ -108,7 +108,7 @@ public class RangerKafkaAuthorizer implements Authorizer { rangerResource.setValue(KEY_TOPIC, resource.name()); } else if (resource.resourceType().equals(ResourceType.CLUSTER)) { rangerResource.setValue(KEY_CLUSTER, resource.name()); - } else if (resource.resourceType().equals(ResourceType.GROUP)) { + } else if (resource.resourceType().equals(ResourceType.CONSUMER_GROUP)) { rangerResource.setValue(KEY_CONSUMER_GROUP, resource.name()); } else { logger.fatal("Unsupported resourceType=" + resource.resourceType());
