Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

setup a multi-broker /Kafka/ exception

setup a multi-broker /Kafka/ exception




I would like to set up a multi-broker cluster (kafka) and I followed the instruction on the apache kafka website.

  • I created config-files for each broker and edited them
    • cp config/ config/
    • cp config/ config/
    • cp config/ config/
  • then I tried to start the brokers
    • /bin/ conf/    



But I get following exception:


  1. Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/kafka/common/utils/KafkaThread : Unsupported major.minor version 51.0
  2. at java.lang.ClassLoader.defineClass1(Native Method)
  3. at java.lang.ClassLoader.defineClass(
  4. at
  5. at
  6. at$000(
  7. at$
  8. at$
  9. at Method)
  10. at
  11. at java.lang.ClassLoader.loadClass(
  12. at sun.misc.Launcher$AppClassLoader.loadClass(
  13. at java.lang.ClassLoader.loadClass(
  14. at kafka.utils.Log4jController$.<init>(Log4jController.scala:30)
  15. at kafka.utils.Log4jController$.<clinit>(Log4jController.scala)
  16. at kafka.utils.Logging$class.$init$(Logging.scala:29)
  17. at com.cloudera.kafka.wrap.Kafka$.<init>(Kafka.scala:28)
  18. at com.cloudera.kafka.wrap.Kafka$.<clinit>(Kafka.scala)
  19. at com.cloudera.kafka.wrap.Kafka.main(Kafka.scala)


Can someone help me with the exception? I do not know what to do now.



Re: setup a multi-broker /Kafka/ exception

Cloudera Employee

Seems like you are using jdk 1.7 which is not compatible with the kafka
version being used. Using jdk 1.8 should resolve this issue. Also see the
following link: