在linux上安裝Kafka，步驟如下：

第一步：安裝Java jdk

1.到官網複製下載連結

官網地址：

http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

2.在xshell上輸入命令

wget --no-check-certificate --no-cookies --header "Cookie: oraclelicense=accept-securebackup-cookie"

後面加上剛才複製的下載連結

示例如下：

wget --no-check-certificate --no-cookies --header "Cookie: oraclelicense=accept-securebackup-cookie" 

http://download.oracle.com/otn-pub/java/jdk/8u181-b13/96a7b8442fe848ef90c96a2fad6ed6d1/jdk-8u181-linux-x64.tar.gz
 

3.下載完成之後解壓

tar -zxvf  jdk-8u151-linux-x64.tar.gz

4.編輯配置檔案，配置環境變數

vim  /etc/profile

新增如下內容：（JAVA_HOME根據實際目錄來）

#set java environment
JAVA_HOME=/usr/local/jdk/jdk1.8.0_151
CLASSPATH=$JAVA_HOME/lib/
PATH=$PATH:$JAVA_HOME/bin
export PATH JAVA_HOME CLASSPATH

5.使配置生效：
重新載入配置檔案，執行命令（推薦這種方式） ：

source /etc/profile

或者，重啟機器 

sudo shutdown -r now

6.檢視安裝情況

java -version

安裝成功，則出現java版本資訊：

java version "1.8.0_151"
Java(TM) SE Runtime Environment (build 1.8.0_151-b01)
Java HotSpot(TM) 64-Bit Server VM (build 25.151-b01, mixed mode)

第二步：安裝zookper：

1. 到官網檢視下載的版本
下載地址：

https://mirrors.cnnic.cn/apache/zookeeper/stable/
 

2.下載命令：

wget https://mirrors.cnnic.cn/apache/zookeeper/stable/zookeeper-3.4.12.tar.gz

3.解壓縮指定目錄（/home/work/soft/）

tar -zxvf zookeeper-3.4.12.tar.gz

4.修改配置檔案：

# 複製一份zoo_sample.cfg檔案，並改名為zoo.cfg
sudo cp home/work/soft/zookeeper/zoo_sample.cfg zoo.cfg
# 編輯zoo.cfg 檔案
sudo vim home/work/soft/zookeeper/zoo.cfg
#主要修改dataDir和server.1=127.0.0.1:2888:3888這2處
# the directory where the snapshot is stored.
dataDir=home/work/soft/zookeeper/data
# the port at which the clients will connect
clientPort=2181
server.1=127.0.0.1:2888:3888

5.啟動zookeeper：

/home/work/soft/zookeeper-3.4.12/bin/zkServer.sh start /home/work/soft/zookeeper-3.4.12/conf/zoo.cfg &

第三步：安裝kafka2.12

1. 到官網檢視下載的版本
下載地址：

http://mirror.bit.edu.cn/apache/kafka/2.0.0/

2.下載命令：

wget http://mirror.bit.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz

3.解壓縮指定目錄（/home/work/soft/）

tar -zxvf kafka_2.12-2.0.0.tgz

4.修改配置檔案：

#建立日誌存放目錄
cd /home/work/soft/kafka/
mkdir -p log/kafka
#修改配置檔案 /home/work/soft/kafka/config/server.properties
sudo vim /home/work/soft/kafka/config/server.properties
#主要修改下面幾項內容如下：
broker.id=181
delete.topic.enable=true
listeners = PLAINTEXT://127.0.0.1:9092
log.dirs=/home/work/soft/kafka/log/kafka
zookeeper.connect=127.0.0.1:2181

5.啟動kafka：

/home/work/soft/kafka_2.12-2.0.0/bin/kafka-server-start.sh /home/work/soft/kafka_2.12-2.0.0/config/server.properties &

6. 建立1個topic：

cd /home/work/soft/kafka_2.12-2.0.0
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test_log

7. 列出topic：

bin/kafka-topics.sh --list --zookeeper localhost:2181

8. 生產者：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test_log

9. 消費者：

從一個topic上取訊息

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_log --from-beginning

參考資料：

https://www.cnblogs.com/Yang2012/p/8078586.html

https://blog.csdn.net/shubingzhuoxue/article/details/82868956