You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ranger.apache.org by sn...@apache.org on 2015/05/25 16:37:58 UTC
[06/15] incubator-ranger git commit: RANGER-496 Fix build failure due
to Kafka API change
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 <bo...@apache.org>
Authored: Tue May 19 15:53:49 2015 -0700
Committer: Don Bosco Durai <bo...@apache.org>
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());