Как исправить «java.lang.UnsupportedClassVersionError» на kafka-start-server.sh

Question

Я пытаюсь установить kafka на Cloudera quickstart vm.Я сделал все шаги.Но я получаю следующую ошибку при запуске сервера kafka:

Исключение в потоке "main" java.lang.UnsupportedClassVersionError: org / apache / kafka / common / utils / KafkaThread: не поддерживаетсяMajor.minor версия 52.0 на java.lang.ClassLoader.defineClass1 (собственный метод)

В моем .bashrc файле

export PATH="/usr/java/jdk1.8.0_211/bin:$PATH"

export KAFKA_HOME="/opt/kafka/kafka_2.11-2.2.0"
export PATH="$KAFKA_HOME/bin:$PATH"

export KAFKA_CLASSPATH="$KAFKA_HOME/libs/"
export KAFKA_CONF_DIR="$KAFKA_HOME/config/"

установлены следующие переменные окруженияс использованием java 7 и java 8, но ошибка по-прежнему сохраняется.

Заранее благодарим за помощь.

Answer 1

Kafka пытается найти команду Java в JAVA_HOME

Попробуйте

export JAVA_HOME=/usr/java/jdk1.8.0_211
export PATH="$JAVA_HOME/bin:$PATH"

kafka-server-start server.properties

Примечание: вам не нужна среда Hadoop для запуска Kafka, поэтому просто новая виртуальная машина с Java8 (или 11) будет работать с последней Kafka.

Или вы можете использовать Docker