CentOS 7.6

JDK 1.8

ZooKeeper 3.5.7

Kafka 2.11-2.4.0

安裝JDK

解壓

# 解壓
tar -xzvf jdk-8u181-linux-x64.tar.gz
mv jdk1.8.0_181 /usr/local/jdk1.8

環(huán)境變量

# 打開(kāi).bashrc文件
vi ~/.bashrc# 文件末尾添加如下內(nèi)容
export JAVA_HOME=/usr/local/jdk1.8
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH# 輸入下面的命令使之生效
source ~/.bashrc

驗(yàn)證

打開(kāi)命令行終端，輸入如下命令：

java -version

顯示版本信息，說(shuō)明安裝成功

安裝ZooKeeper

下載

點(diǎn)擊官網(wǎng)下載

解壓

# 解壓
tar -xzvf apache-zookeeper-3.5.7-bin.tar.gz
sudo mv apache-zookeeper-3.5.7-bin /usr/local/zookeeper-3.5.7

環(huán)境變量

# 打開(kāi)/etc/profile
vi /etc/profile# 添加如下內(nèi)容，然后保存
export ZOOKEEPER_HOME=/usr/local/zookeeper-3.5.7
export PATH=.:$ZOOKEEPER_HOME/bin:$JAVA_HOME/bin:$PATH# 重新編譯使環(huán)境變量生效
source /etc/profile

配置

# 切換到conf目錄下
cd /usr/local/zookeeper-3.5.7/conf
# 復(fù)制zoo_sample.cfg到zoo.cfg
cp zoo_sample.cfg zoo.cfg
# 打開(kāi)zoo.cfg
vi zoo.cfg# 修改配置如下，然后保存
# 存放數(shù)據(jù)
dataDir=/usr/local/zookeeper-3.5.7/dataDir
# 存放日志文件
dataLogDir=/usr/local/zookeeper-3.5.7/dataLogDir
# 端口默認(rèn)為2181，單機(jī)版可不配置
clientPort=2181# 創(chuàng)建文件夾
mkdir /usr/local/zookeeper-3.5.7/dataDir
mkdir /usr/local/zookeeper-3.5.7/dataLogDir

啟動(dòng)

cd /usr/local/zookeeper-3.5.7/bin
# 啟動(dòng)命令
./zkServer.sh start
# 停止命令
./zkServer.sh stop

開(kāi)放端口

如果需要允許其他機(jī)器訪問(wèn)，需要開(kāi)放2181端口

firewall-cmd --add-port=2181/tcp --permanent
firewall-cmd --reload

安裝Kafka

下載

點(diǎn)擊官網(wǎng)下載

解壓

# 解壓
tar -zxf kafka_2.11-2.4.0.tgz
# 復(fù)制到 /usr/local 目錄
mv kafka_2.11-2.4.0 /usr/local/kafka_2.11-2.4.0

配置

cd /usr/local/kafka_2.11-2.4.0/config
vi server.properties# 增加如下配置，ip為kafka所在服務(wù)器的地址(內(nèi)網(wǎng)ip)
listeners=PLAINTEXT://182.43.11.48:9092
# 增加如下配置，可選，ip為kafka所在服務(wù)器的地址(供外部訪問(wèn)的ip)
advertised.listeners=PLAINTEXT://182.43.11.48:9092
# 增加如下配置，zookeeper所在服務(wù)器的地址
zookeeper.connect=182.43.11.48:2181# 保存
:wq

啟動(dòng)

# 進(jìn)入安裝目錄
cd /usr/local/kafka_2.11-2.4.0
# 啟動(dòng)
nohup bin/kafka-server-start.sh config/server.properties &
# kafka占用端口9092，查看監(jiān)聽(tīng)情況
netstat -tunlp | egrep 9092# 開(kāi)放9092端口
firewall-cmd --add-port=9092/tcp --permanent
firewall-cmd --reload# 停止
bin/kafka-server-stop.sh config/server.properties