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/6e017928 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/6e017928 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/6e017928 Branch: refs/heads/ranger-0.5 Commit: 6e017928ef11e9031f404ee06a44f659a8192b98 Parents: de5ea54 Author: Don Bosco Durai <[email protected]> Authored: Tue May 19 15:53:49 2015 -0700 Committer: Don Bosco Durai <[email protected]> Committed: Tue May 19 15:55:32 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/6e017928/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());
