搭建kafka集群窍奋，需要先搭建zookeeper集群剩愧，搭建zookeeper集群表谊，依賴于jdk
1.下載安裝jdk8
https://www.oracle.com/java/technologies/javase/javase-jdk8-downloads.html
這里下載的是：jdk-8u291-linux-x64.tar.gz
2.將 jdk-8u291-linux-x64.tar.gz 放到 /usr/local/java/ 目錄
3.執(zhí)行 tar 解壓安裝包
tar -zxvf jdk-8u291-linux-x64.tar.gz
4.配置環(huán)境變量
vim /etc/profile 配置jdk
#jdk
JAVA_HOME=/usr/local/java/jdk1.8.0_291
CLASSPATH=.:$JAVA_HOME/lib.tools.jar
PATH=$JAVA_HOME/bin:$PATH
export JAVA_HOME CLASSPATH PATH
5.執(zhí)行 source /etc/profile 使文件生效
6.下載zookeeper
這里可以看到最新的版本 https://zookeeper.apache.org/releases.html
我使用的是 3.4.14 版本 : zookeeper-3.4.14.tar.gz
下載的是源碼版本橘沥，不要下載錯(cuò)了
7.將 zookeeper-3.4.14.tar.gz 放到提前準(zhǔn)備好的安裝目錄 /mnt/data
- 進(jìn)入目錄：mnt/data
9.tar -zxvf zookeeper-3.4.14.tar.gz 解壓文件
10.cd /zookeeper-3.4.14/conf
- cp zoo_sample.cfg zoo.cfg復(fù)制一份配置文件并重命名zoo.cfg
12.vim zoo.cfg
12.修改dataDir路徑 dataDir=/mnt/data/zookeeper-3.4.14/data
13.添加三臺(tái)服務(wù)器集群
server.1=0.0.0.0:2888:3888
server.2=10.0.0.12:2888:3888
server.3=10.0.0.13:2888:3888
14.切換到 zookeeper-3.4.14 文件夾下
- mkdir data 創(chuàng)建data目錄
16.cd data 切換到data目錄
17.vim myid 輸入1 然后 保存
這個(gè)1對(duì)應(yīng)的是server集群的1 其他兩個(gè)文件的myid分別對(duì)應(yīng)的是2和3
18.vim /etc/profile 配置zookeeper
#zookeeper
export ZOOKEEPER_HOME=/mnt/data/zookeeper-3.4.14
#export PATH=$PATH:$ZOOKEEPER_HOME/bin:$ZOOKEEPER_HOME/conf
19.保存 并執(zhí)行source /etc/profile 使文件生效
20.到這里先不要啟動(dòng)毅戈，再按照上面的說明配置其他兩臺(tái)服務(wù)器
21.啟動(dòng)zookeeper命令 切換到bin目錄 執(zhí)行 shServer.sh start
zkServer.sh status 看到一下內(nèi)容即為集群成功 兩臺(tái)服務(wù)器是 follower 一臺(tái)服務(wù)器是 leader
[root@ecs-e50ota-0010 bin]# zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /mnt/data/zookeeper-3.4.14/bin/../conf/zoo.cfg
Mode: follower
以上是zookeeper集群搭建搓扯，下面是kafka集群搭建
——————————————————————————————————————————
22.下載kafka 這里是中文官網(wǎng)地址 http://kafka.apachecn.org/
這里是最新版本地址 http://kafka.apachecn.org/downloads.html
下載的時(shí)候使用二進(jìn)制文件检痰，請(qǐng)勿使用源碼src文件
我使用的是2.11-1.0.0版本 下載地址是 : https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka_2.11-1.0.0.tgz
23.將文件kafka_2.11-1.0.0.tgz放到 /mnt/data/ 目錄下
- tar -zxvf kafka_2.11-1.0.0.tgz 解壓文件
25.切換目錄 cd /usr/local/kafka_2.11-1.0.0/config
26.編輯配置文件 vi server.properties
27.需要改動(dòng)三個(gè)地方
27.1 broker.id=1 和myid相對(duì)應(yīng)
27.2 原來的listeners是被注釋的，打開注釋锨推，修改成 只需替換自己服務(wù)器的ip即可
listeners=PLAINTEXT://10.0.0.11:9092 每臺(tái)服務(wù)器使用各自的ip
27.3 原來的zookeeper.connect=localhost:2181是單機(jī)版的铅歼，我們搭建集群修改為自己的服務(wù)器ip公壤，逗號(hào)分隔
zookeeper.connect=10.0.0.11:2181,10.0.0.12:2181,10.0.0.13:2181 三臺(tái)服務(wù)器使用相同的配置
- vim /etc/profile 配置kafka相關(guān)
#kafka
export KAFKA_HOME=/mnt/data/kafka_2.11-1.0.0
export PATH=$PATH:${KAFKA_HOME}/bin:$ZOOKEEPER_HOME/bin:$ZOOKEEPER_HOME/conf
29.執(zhí)行 source /etc/profile使文件生效
30.其他兩臺(tái)服務(wù)器使用相同配置 只需改動(dòng) broker.id 和 listeners
31.使用 ./bin/kafka-server-start.sh -daemon config/server.properties 命令啟動(dòng)或者
nohup /user/local/kafka_2.11-1.0.0/bin/kafka-server-start.sh /user/local/kafka_2.11-1.0.0/config/server.properties &
32.檢查是否啟動(dòng)成功使用 ps -ef | grep kafka 顯示一下內(nèi)容即為啟動(dòng)成功
33.查看日志 切換到 日志目錄 /usr/local/kafka_2.11-1.0.0/logs
————————————————
參考鏈接：https://blog.csdn.net/u011421988/article/details/106476157
