一、安装和部署
1、上传并解压安装包
tar -zxvf kafka_2.12-3.3.1.tgz -C /opt/program/
2、修改解压后的文件名称
cd /opt/program/
mv kafka_2.12-3.3.1/ kafka
3、进入到/opt/program/kafka 目录,修改配置文件
cd config/
vim server.properties
输入以下内容:
4、分发到slave1和slave2
scp -r /opt/program/kafka root@slave1:/opt/program/
scp -r /opt/program/kafka root@slave2:/opt/program/
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
6、配置环境变量
vim /etc/profile
添加以下内容:
#KAFKA_HOME
export KAFKA_HOME=/opt/program/kafka
export PATH=$PATH:$KAFKA_HOME/bin
source /etc/profile
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
(3)查看进程
jps
--------- master----------
3768 QuorumPeerMain
4251 Kafka
4349 Jps
--------- slave1----------
4769 Kafka
4292 QuorumPeerMain
4878 Jps
--------- slave2----------
3298 Jps
3206 Kafka
2719 QuorumPeerMain
9、关闭集群
bin/kafka-server-stop.sh
问题收集:
https://blog.csdn.net/qq_39545674/article/details/108889030
版权归原作者 ordo120 所有, 如有侵权,请联系我们删除。