0


Kafka案例1-Kafka的安装

一、安装和部署
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

标签: kafka

本文转载自: https://blog.csdn.net/ordo120/article/details/138489902
版权归原作者 ordo120 所有, 如有侵权,请联系我们删除。

“Kafka案例1-Kafka的安装”的评论:

还没有评论