1. 組件版本

組件	版本
CentOS	7.6
JDK	1.8.0_221
kafka	2.13-3.0.0

這里簡單解釋一下kafka的版本號：因為kafka主要是使用scala語言開發的，2.13為scala的版本號；http://kafka.apache.org/downloads可以查看到每個版本的發布時間，

2.環境設定

Init-env.sh腳本：

#!/bin/bash
 
echo "----------------關閉selinux-----------------"
sed -i 's#SELINUX=enforcing#SELINUX=disabled#g' /etc/sysconfig/selinux && sed -i 's#SELINUX=enforcing#SELINUX=disabled#g' /etc/selinux/config
 
echo "----------------關閉swap--------------------"
swapoff -a && sed -ri 's/.*swap.*/#&/' /etc/fstab

#使配置立即生效
setenforce 0
 
echo "----------------開放9092埠-----------------"
cat <<EOF>> /etc/sysconfig/iptables
-A INPUT -p tcp -m state --state NEW -m tcp --dport 9092 -j ACCEPT
EOF

#最后重啟防火墻使配置生效
service iptables restart

注意：

如果在win10系統里面，ping IP地址是通的，但是 telnet ip port不通時：

第一：開放埠9092
命令：firewall-cmd --zone=public --add-port=9092/tcp --permanent

第二：防火墻重新加載
命令：firewall-cmd --reload

第三：后邊修改kafka的server.properties檔案，

3.安裝JDK

安裝步驟省略，注意環境變數配置即可，

export JAVA_HOME=/root/jdk/jdk1.8.0_221
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin

4.安裝kafka

kafka官網下載地址：Apache Kafka

解壓：tar -zxvf kafka_2.13-3.0.0

修改kafka組態檔：

在server.properties檔案內編輯監聽地址為本機地址即可，

listeners=PLAINTEXT://192.168.0.213:9092

advertised.listeners=PLAINTEXT://192.168.0.213:9092

編輯kafka環境變數：vi /etc/profile

export KAFKA_HOME=/root/kafka/kafka_2.13-3.0.0
export PATH=:$PATH:${KAFKA_HOME}

使編輯生效：source /etc/profile

5.啟動腳本

vi start-kafka.sh

KAFKA_DIR=/root/kafka/kafka_2.13-3.0.0/
nohup sh ${KAFKA_DIR}/bin/zookeeper-server-start.sh -daemon ${KAFKA_DIR}/config/zookeeper.properties > zookeeper.log 2>&1 &
sleep 5
nohup sh ${KAFKA_DIR}/bin/kafka-server-start.sh -daemon ${KAFKA_DIR}/config/server.properties > kafka.log 2>&1 &

給腳本賦權限：chmod +x start-kafka.sh

6.關閉腳本

vi start-kafka.sh

#!/bin/sh
KAFKA_DIR=/root/kafka/kafka_2.13-3.0.0/

#關閉kafka
nohup sh ${KAFKA_DIR}/bin/kafka-server-start.sh ${KAFKA_DIR}/config/server.properties &

sleep 5

#關閉zookeeper
sh ${KAFKA_DIR}/bin/zookeeper-server-start.sh ${KAFKA_DIR}/config/zookeeper.properties &

給腳本賦權限：chmod +x start-kafka.sh

看下埠啟動情況：