kafka 3.0.0 之前 (包括3.0.0版本)支持jdk 8 ,3.0.0之后版本不再支持jdk8版本 ,
按照官網(wǎng)安裝kafka ,出現(xiàn)了各種各樣的問題。
總結(jié):kafka和zookeeper和jdk版本對應,
kafka啟動報錯 根據(jù)提示改正后 需要刪除某些臨時文件內(nèi)容 。
下面整理了kafka安裝的完整步驟,適合所有kafka安裝版本
1. 初始化安裝環(huán)境
1.1 安裝jdk
1.1.1 找到對應的jdk版本
找到kafka 版本的 kafka_2.13-2.6.1/bin/kafka-run-class.sh
文件
找關鍵字 java version
查看kafka 支持的最低jdk版本
# GC options
GC_FILE_SUFFIX='-gc.log'
GC_LOG_FILE_NAME=''
if [ "x$GC_LOG_ENABLED" = "xtrue" ]; then
GC_LOG_FILE_NAME=$DAEMON_NAME$GC_FILE_SUFFIX
# The first segment of the version number, which is '1' for releases before Java 9
# it then becomes '9', '10', ...
# Some examples of the first line of `java --version`:
# 8 -> java version "1.8.0_152"
# 9.0.4 -> java version "9.0.4"
# 10 -> java version "10" 2018-03-20
# 10.0.1 -> java version "10.0.1" 2018-04-17
# We need to match to the end of the line to prevent sed from printing the characters that do not match
JAVA_MAJOR_VERSION=$("$JAVA" -version 2>&1 | sed -E -n 's/.* version "([0-9]*).*$/\1/p')
if [[ "$JAVA_MAJOR_VERSION" -ge "9" ]] ; then
KAFKA_GC_LOG_OPTS="-Xlog:gc*:file=$LOG_DIR/$GC_LOG_FILE_NAME:time,tags:filecount=10,filesize=102400"
else
KAFKA_GC_LOG_OPTS="-Xloggc:$LOG_DIR/$GC_LOG_FILE_NAME -verbose:gc -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=10 -XX:GCLogFileSize=100M"
fi
fi
1.1.2 下載并安裝
具體的jdk版本 看kafka
1.1.2.1 配置jdk環(huán)境變量
// 配置jdk環(huán)境變量
vim /etc/profile
文末加:
export JAVA_HOME=/opt/jdk1.8.0_24 # 自己的jdk安裝路徑 ,根據(jù)情況修改
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
保存后
// 配置文件生效
source /etc/ profile
測試
[root@localhost opt]# java -version
java version "1.8.0_241"
Java(TM) SE Runtime Environment (build 1.8.0_241-b07)
Java HotSpot(TM) 64-Bit Server VM (build 25.241-b07, mixed mode)
1.2 安裝 zookeeper
1.2.1 查找kafka對應zookeeper版本
下載對應 的zookeeper 版本,查找辦法 :下載kafka src 源文件 kafka-2.6.0-src.tgz (asc, sha512) ,解壓打開相對路徑的 kafka-2.6.0-src\gradle
的dependencies.gradle
文件,搜索關鍵字zookeeper
關鍵字
zookeeper: "3.5.8",
到zookeeper官網(wǎng)下載zookeeper 3.5.8
下載文件名含bin的壓縮包,要不然啟動報錯
要啟動 ZooKeeper,您需要一個配置文件。這是一個示例,在conf/zoo.cfg中創(chuàng)建它:
tickTime=2000
dataDir=/var/lib/zookeeper
clientPort=2181
啟動
文章來源:http://www.zghlxwxcb.cn/news/detail-483080.html
2. 下載kafka 安裝包
下載地址 ,官網(wǎng)包下載地址,具體命令操作參考官網(wǎng)文章來源地址http://www.zghlxwxcb.cn/news/detail-483080.html
到了這里,關于liunx服務器安裝kafka的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章,希望大家以后多多支持TOY模板網(wǎng)!