1 安裝java環(huán)境

1.1 下載linux下的安裝包

（1）登錄官網(wǎng)下載地址，找到對應(yīng)壓縮包。

（2）點擊下載鏈接彈出如下窗口，勾選協(xié)議，繼續(xù)點擊下載鏈接。

（3）需要登錄賬戶。如果已經(jīng)有賬戶則直接登錄；沒有就需要注冊一個賬戶。登錄賬戶后就可以直接下載了。

1.2 解壓縮安裝包

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

解壓后的文件夾為jdk1.8.0_351，進入文件夾和查看文件：

cd jdk1.8.0_351
ls

可以看到bin目錄：

bin        	include         					jmc.txt  
legal  			LICENS							README.html  
src.zip     	THIRDPARTYLICENSEREADME.txt		COPYRIGHT  
javafx-src.zip  jre      						lib    
man      		release      					THIRDPARTYLICENSEREADME-JAVAFX.txt

1.3 解壓后的文件移到/usr/lib目錄下

（1）將解壓后的文件移到/usr/lib目錄下：

sudo mkdir /usr/lib/jdk

（2）將解壓的jdk文件移動到新建的/usr/lib/jdk目錄下來：

sudo mv jdk1.8.0_351 /usr/lib/jdk/

1.4 配置java環(huán)境變量

這里是將環(huán)境變量配置在etc/profile，即為所有用戶配置JDK環(huán)境。

（1）使用命令打開/etc/profile文件：

sudo vim /etc/profile

（2）在末尾添加以下幾行：

#set java env 
export JAVA_HOME=/usr/lib/jdk/jdk1.8.0_351 
export JRE_HOME=${JAVA_HOME}/jre     
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib     
export PATH=${JAVA_HOME}/bin:$PATH

（3）執(zhí)行命令使修改立即生效：

source /etc/profile

（4）測試安裝是否成功：

java -version

出現(xiàn)版本號說明安裝成功。

java version "1.8.0_351"
Java(TM) SE Runtime Environment (build 1.8.0_351-b10)
Java HotSpot(TM) 64-Bit Server VM (build 25.351-b10, mixed mode)

2 kafka的安裝部署

2.1 下載安裝kafka

（1）下載Kafka。

wget https://archive.apache.org/dist/kafka/2.0.0/kafka_2.11-2.0.0.tgz

（2）解壓縮Kafka。下載的kafka是已經(jīng)編譯好的程序，只需要解壓即可得到執(zhí)行程序。

tar -zxvf kafka_2.11-2.0.0.tgz

（3）進入kafka目錄，以及查看對應(yīng)的文件和目錄。

cd kafka_2.11-2.0.0 
ls

bin：為執(zhí)行程序
config：為配置文件
libs：為庫文件

bin  config  libs  LICENSE  NOTICE  site-docs

2.2 配置和啟動zookeeper

Kafka 3.0開始將zookeeper剝離出去了，下載的版本是2.11程序里自帶了zookeeper，kafka自帶的Zookeeper程序腳本與配置文件名與原生Zookeeper稍有不同。

kafka自帶的Zookeeper程序使用bin/zookeeper-server-start.sh，以及bin/zookeeper-server-stop.sh來啟動和停止Zookeeper。

# 啟動zookeeper：
zookeeper-server-start.sh # 停止zookeeper：
zookeeper-server-stop.sh

kafka依賴于zookeeper來做master選舉以及其他數(shù)據(jù)的維護。
在con?g目錄下，存在一些配置文件：

zookeeper.properties 
server.properties

因此可以通過下面的腳本來啟動zookeeper服務(wù)，當然，也可以自己獨立搭建zookeeper的集群來實現(xiàn)。這里我們直接使用kafka自帶的zookeeper。

cd bin/
# 前臺運行：
sh zookeeper-server-start.sh  ../config/zookeeper.properties# 后臺運行：
sh zookeeper-server-start.sh -daemon ../config/zookeeper.properties

啟動zookeeper，默認端口為：2181，可以通過命令lsof -i:2181 查看zookeeper是否啟動成功。

COMMAND    PID USER   FD   TYPE  DEVICE SIZE/OFF NODE NAME
java    128387  fly   96u  IPv6 2591167      0t0  TCP *:2181 (LISTEN)

2.3 啟動和停止kafka

（1）修改server.properties（在config目錄）, 增加zookeeper的配置，這里只是本地的配置，如果是另一臺機器運行zookeeper，要配置對應(yīng)的ip地址。

############################# Zookeeper ############################## Zookeeper connection string (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
# You can also append an optional chroot string to the urls to specify the
# root directory for all kafka znodes.
zookeeper.connect=localhost:2181# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000

（2）啟動kafka（kafka安裝路徑的bin目錄下執(zhí)行），默認啟動端口9092。

sh kafka-server-start.sh -daemon ../config/server.properties

（3）停止kafka（kafka安裝路徑的bin目錄下執(zhí)行）。

sh kafka-server-stop.sh -daemon ../config/server.properties