Support Questions
Find answers, ask questions, and share your expertise

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.



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: