java - 如何修复 kafka-start-server.sh 上的 "java.lang.UnsupportedClassVersionError"

Question

我正在尝试在 Cloudera 快速启动虚拟机上安装 kafka。我已经完成了所有步骤。但在启动 kafka 服务器时出现以下错误:

Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/kafka/common/utils/KafkaThread : Unsupported major.minor version 52.0 at java.lang.ClassLoader.defineClass1(Native Method)

我在 .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_HOME 查找 Java 命令

尝试

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

kafka-server-start server.properties

注意:您不需要 Hadoop 环境来运行 Kafka，因此只需使用 Java 8(或 11)的全新虚拟机即可使用最新的 Kafka。

或者你可以使用 Docker