Hello,
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/server.properties config/server.1.properties
- cp config/server.properties config/server.2.properties
- cp config/server.properties config/server.3.properties
- then I tried to start the brokers
- /bin/kafka-server-start.sh conf/server.1.properties
But I get following exception:
- Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/kafka/common/utils/KafkaThread : Unsupported major.minor version 51.0
- at java.lang.ClassLoader.defineClass1(Native Method)
- at java.lang.ClassLoader.defineClass(ClassLoader.java:648)
- at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
- at java.net.URLClassLoader.defineClass(URLClassLoader.java:272)
- at java.net.URLClassLoader.access$000(URLClassLoader.java:68)
- at java.net.URLClassLoader$1.run(URLClassLoader.java:207)
- at java.net.URLClassLoader$1.run(URLClassLoader.java:201)
- at java.security.AccessController.doPrivileged(Native Method)
- at java.net.URLClassLoader.findClass(URLClassLoader.java:200)
- at java.lang.ClassLoader.loadClass(ClassLoader.java:325)
- at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:296)
- at java.lang.ClassLoader.loadClass(ClassLoader.java:270)
- at kafka.utils.Log4jController$.<init>(Log4jController.scala:30)
- at kafka.utils.Log4jController$.<clinit>(Log4jController.scala)
- at kafka.utils.Logging$class.$init$(Logging.scala:29)
- at com.cloudera.kafka.wrap.Kafka$.<init>(Kafka.scala:28)
- at com.cloudera.kafka.wrap.Kafka$.<clinit>(Kafka.scala)
- at com.cloudera.kafka.wrap.Kafka.main(Kafka.scala)
Can someone help me with the exception? I do not know what to do now.
