ranger-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-ranger git commit: RANGER-496 Fix build failure due to Kafka API change
Date Tue, 19 May 2015 23:03:38 GMT
Repository: incubator-ranger
Updated Branches:
  refs/heads/master de5ea5421 -> 6e017928e


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/master
Commit: 6e017928ef11e9031f404ee06a44f659a8192b98
Parents: de5ea54
Author: Don Bosco Durai <bosco@apache.org>
Authored: Tue May 19 15:53:49 2015 -0700
Committer: Don Bosco Durai <bosco@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());


Mime
View raw message