Aneela, 

Kafka plugin is not officially supported in Ranger 0.5. The code currently
in the source code is built after applying the public patches in Kafka which
contains Authorization interfaces. However, the code on the Kafka side is
been rapidly evolving and not yet committed. We anticipate, that the Kafka
side code will be committed in Kafka 0.9. There is discussion going on in
Kafka community for the release, but there is no ETA.

You should wait till Kafka 0.9 is released. After that we will have to one
more revision to the existing code to make it compatible.

Thanks

Bosco


From:  Aneela Saleem <[email protected]>
Reply-To:  <[email protected]>
Date:  Wednesday, September 16, 2015 at 5:01 AM
To:  <[email protected]>
Subject:  Issues enabling Ranger Kafka Plugin

> Hi all, 
> 
> I'm adding Kafka Plugin for Ranger. When i run the script
> enable-kafka-plugin.sh, I get the following errors:
> 
> Unable to store password in non-plain text format. Error: [Exception in thread
> "main" java.lang.NoClassDefFoundError:
> org/apache/commons/configuration/Configuration
> at 
> org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.<init>(DefaultMetricsSyste
> m.java:38)
> at 
> org.apache.hadoop.metrics2.lib.DefaultMetricsSystem.<clinit>(DefaultMetricsSys
> tem.java:36)
> at 
> org.apache.hadoop.security.UserGroupInformation$UgiMetrics.create(UserGroupInf
> ormation.java:120)
> at 
> org.apache.hadoop.security.UserGroupInformation.<clinit>(UserGroupInformation.
> java:236)
> at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:2812)
> at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:2802)
> at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2668)
> at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:371)
> at org.apache.hadoop.fs.Path.getFileSystem(Path.java:295)
> at 
> org.apache.hadoop.security.alias.JavaKeyStoreProvider.<init>(JavaKeyStoreProvi
> der.java:90)
> at 
> org.apache.hadoop.security.alias.JavaKeyStoreProvider.<init>(JavaKeyStoreProvi
> der.java:67)
> at 
> org.apache.hadoop.security.alias.JavaKeyStoreProvider$Factory.createProvider(J
> avaKeyStoreProvider.java:291)
> at 
> org.apache.hadoop.security.alias.CredentialProviderFactory.getProviders(Creden
> tialProviderFactory.java:58)
> at 
> org.apache.ranger.credentialapi.CredentialReader.getDecryptedString(Credential
> Reader.java:58)
> at org.apache.ranger.credentialapi.buildks.createCredential(buildks.java:86)
> at org.apache.ranger.credentialapi.buildks.main(buildks.java:39)
> Caused by: java.lang.ClassNotFoundException:
> org.apache.commons.configuration.Configuration
> at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
> at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
> at java.security.AccessController.doPrivileged(Native Method)
> at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
> ... 16 more]
> 
> Attached is the install.properties file. Please guide me what is the issue?
> Although i have ranger_credential_helper.py file in the plugin folder.
> 


Reply via email to