Posts: 7
Registered: ‎08-29-2018

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
Posts: 61
Registered: ‎04-24-2017

Re: setup a multi-broker /Kafka/ exception


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:

New solutions