Kafka案例1-Kafka的安装

一、安装和部署
1、上传并解压安装包

tar -zxvf kafka_2.12-3.3.1.tgz -C /opt/program/
1

2、修改解压后的文件名称

cd /opt/program/
mv kafka_2.12-3.3.1/ kafka
1
2

3、进入到/opt/program/kafka 目录，修改配置文件

cd config/
vim server.properties
1
2

输入以下内容：

4、分发到slave1和slave2

scp -r /opt/program/kafka root@slave1:/opt/program/
scp -r /opt/program/kafka root@slave2:/opt/program/
1
2

5、分别在 slave1和 slave2上修改配置文件
kafka/config/server.properties 中的 broker.id 及 advertised.listeners
注：broker.id 不得重复，整个集群中唯一。

vim kafka/config/server.properties

分别在slave1和slave2中进行以下修改：

broker.id=1
#broker 对外暴露的 IP 和端口 （每个节点单独配置）
advertised.listeners=PLAINTEXT://slave1:9092

broker.id=2
#broker 对外暴露的 IP 和端口 （每个节点单独配置）
advertised.listeners=PLAINTEXT://slave2:9092
1
2
3
4
5
6
7
8
9
10
11

6、配置环境变量

vim /etc/profile
添加以下内容：
#KAFKA_HOME
export KAFKA_HOME=/opt/program/kafka
export PATH=$PATH:$KAFKA_HOME/bin
source /etc/profile
1
2
3
4
5
6

7、分发环境变量文件到其他节点，并 source。
scp /etc/profile root@slave1:/etc/profile
scp /etc/profile root@slave2:/etc/profile

8、启动集群
（1）先启动zookeeper集群，然后启动kafka。（参考上一个教程）
（2）依次在master、slave1和slave2节点上启动kafka

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

（3）查看进程

jps
--------- master----------
3768 QuorumPeerMain
4251 Kafka
4349 Jps
--------- slave1----------
4769 Kafka
4292 QuorumPeerMain
4878 Jps
--------- slave2----------
3298 Jps
3206 Kafka
2719 QuorumPeerMain
1
2
3
4
5
6
7
8
9
10
11
12
13

9、关闭集群

bin/kafka-server-stop.sh
1

问题收集：
https://blog.csdn.net/qq_39545674/article/details/108889030