it works with the following command: kafka-topics --create --zookeeper cloudera01 --topic ggz --partitions 1 --replication-factor 1 kafka-console-producer --broker-list cloudera02:9092 --topic ggz kafka-console-consumer --zookeeper cloudera01:2181 --topic ggz --from-beginning ... View more

we followed this official link to test kafka: http://www.cloudera.com/documentation/kafka/latest/topics/kafka_command_line.html not sure why ther's no any error message, it got back to prompt ... View more

after setting java home to 1.7, there's no error and nothering happened as follows: root@cloudera01:~# kafka-topics.sh --zookeeper cloudera01.pscsi.com:2181 --list root@cloudera01:~# kafka-topics --zookeeper cloudera01.pscsi.com:2181 --list root@cloudera01:~# any advice would be appreciated. ... View more

 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) ... View more

yes, Frozenwave's solution works,  thanks  ... View more

Hi, any more advicde would be appreciated... ... View more

yes, without selecting mirror , we can press continue, then we hit the following errors as attached,   any further advice would be appreciated   ... View more

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     ... View more

yes, it's been solved, please close this one, thanks ... View more