Created on 05-06-2016 02:16 AM - edited 09-16-2022 03:17 AM
Dear All:
We'd like to add a Kafka service on cloudera manager failed, here's the step to reproduce:
1. install Kafka parcel and active it successfully
2. adding a service from cloudera manager failed , on the destination broker list and source broker list:
Please take a look at the attached , any advice would be appreciated
Regards,
Joe
Created 05-17-2016 02:15 PM
Want to get a detailed solution you have to login/registered on the community
Register/LoginCreated 05-07-2016 01:11 AM
Hi joeyang,
Which Kafka version is it? (1.4 or 2.0)
Does the parcel tab show kafka service as activated?
While adding the service it just asks for broker instances and mirrormaker is optional.
At what stage do you get the error?
Created on 05-08-2016 06:11 PM - edited 05-08-2016 08:05 PM
Hi, Siddesh2104
Thanks for prompt response,
1. csd(kafka-1.2.0.jar) from http://archive.cloudera.com/csds/kafka/
parcel(KAFKA-2.0.1-1.2.0.1.p0.5-trusty.parcel) from: http://archive.cloudera.com/kafka/parcels/latest/
3. yes, parcel has been activated as attached
4. the red color warning message prevent us from clicking "continue", we got stuck on the page as attached, nothing happened after we pressed "continue"
Any more advice would be appreciated.
Thanks
Joe
Created 05-08-2016 09:54 PM
While adding the Kafka service, have you added mirrormaker role as well?
If yes, can you try without adding it?
Created on 05-08-2016 10:47 PM - edited 05-09-2016 02:56 AM
yes, without selecting mirror , we can press continue, then we hit the following errors as attached,
any further advice would be appreciated
Created 05-09-2016 08:27 PM
Created 05-17-2016 02:15 PM
Want to get a detailed solution you have to login/registered on the community
Register/LoginCreated on 05-25-2016 12:38 AM - edited 05-25-2016 12:39 AM
yes, Frozenwave's solution works, thanks
Created on 05-25-2016 01:51 AM - edited 05-25-2016 01:57 AM
A quick test failed with the following error, any advice would be appreciated:
root@cloudera01:/opt/cloudera/parcels/KAFKA-2.0.1-1.2.0.1.p0.5/lib/kafka/bin# ./kafka-topics.sh --zookeeper cloudera01.pscsi.com:2181 --list
Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/kafka/common/config/ConfigDef$Validator : Unsupported major.minor version 51.0
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
at java.lang.ClassLoader.defineClass(ClassLoader.java:615)
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
at java.net.URLClassLoader.access$000(URLClassLoader.java:58)
at java.net.URLClassLoader$1.run(URLClassLoader.java:197)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:288)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:41)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Created 05-25-2016 02:47 AM