1、下载Kafka安装包

https://kafka.apache.org/downloads  官方推荐2.13，我下载的2.12

 2、三台服务器准备

参考从零开始搭建Hadoop集群_不图安逸的小码农的博客-CSDN博客

3、上传Kafka安装包

上传Kafka安装包到node1，software文件夹用作上传安装包，解压位置server文件夹

 

 4、解压安装包到server文件夹

 tar -zxvf kafka_2.12-3.2.1.tgz -C ../server/

 5、进入config文件夹，配置文件

cd kafka_2.12-3.2.1/config/
 
vim server.properties 
 

broker.id=0
 
 
#找到日志文件存放位置，改到安装的kafka下data文件夹
log.dirs=/export/server/kafka_2.12-3.2.1/data

6、发送到另外两台虚拟机

#node1到server目录下
/export/server
 
scp -r kafka_2.12-3.2.1/ node2:$PWD
 
scp -r kafka_2.12-3.2.1/ node3:$PWD
 
#复制完，到node2\node3上查看 /export/server 下是否已有Kafka
 

7、修改node2\node3上的broker.id参数

修改另外两个节点的broker.id分别为1和2
 
---------node2--------------
 
cd /export/server/kafka_2.12-3.2.1/config
 
vim server.properties
 
broker.id=1
 
---------node2--------------
 
cd /export/server/kafka_2.12-3.2.1/config
 
vim server.properties
 
broker.id=2
 

8、配置KAFKA_HOME环境变量

vim /etc/profile
 
export KAFKA_HOME=/export/server/kafka_2.12-3.2.1
export PATH=:$PATH:${KAFKA_HOME}

9、发送到node2\node3

scp /etc/profile node2:$PWD
 
scp /etc/profile node3:$PWD

10、三台均加载环境变量

source /etc/profile

11、启动

这里的zookeeper要提前安装

# 启动ZooKeeper
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
 
也可以集群分别启动zookeeper，利用status查看启动状态
 
 
 
 
 
 
# 启动Kafka
cd /export/server/kafka_2.12-3.2.1
nohup bin/kafka-server-start.sh config/server.properties &
 
# 测试Kafka集群是否启动成功
bin/kafka-topics.sh --bootstrap-server node1:9092 --list