kafka集群报错

Posted students

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka集群报错相关的知识,希望对你有一定的参考价值。

bin/kafka-server-start.sh config/server.properties ,问题来了 :

[[email protected] kafka_2.12-0.10.2.0]# Exception in thread "main" java.lang.UnsupportedClassVersionError: kafka/Kafka : Unsupported major.minor version 52.0
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
at java.lang.ClassLoader.defineClass(ClassLoader.java:615)
 
启动报错,看提示,由于使用最新的kafka版本,需要1.8的JDK。而我本机查看目前是1.6。
 
更换JDK版本
使用wget下载1.8JDK,vim /etc/profile 更改JAVA_HOME的路径,source /etc/profile 后,执行 java -version 仍然显示为 1.6.
重启依然无效,后网上找到解决办法:
which Java
/usr/bin/java
which javac
/usr/bin/javac
 
 
1.先将usr/bin目录下的先删除
rm -rf  java
rm -rf  javac
2.先将jdk1.8
ln -s   $JAVA_HOME/bin/java  /usr/bin/java
ln -s   $JAVA_HOME/bin/javac  /usr/bin/javac

以上是关于kafka集群报错的主要内容,如果未能解决你的问题,请参考以下文章

查看Kafka集群下所有的topic报错“Timed out waiting for a node assignment. Call: listTopics“

防火墙导致zookeeper集群异常,kafka起不来

kafak集群python外网无法访问:kafka.errors.NoBrokersAvailable: NoBrokersAvailable

Kafka(四)集群之kafka

kafka集群配置和使用

kafka集群启动和停止