服务器最全安装、配置、启动Kafka集群
安装、配置、启动Kafka集群
前提必须安装JDK、Zookeeper
在 master 节点操作
（1）切换到 /opt 目录下
cd /opt
（2）从官网下载 kafka 的安装包，并上传至服务器相关目录
（3）解压 kafka 文件到当前目录（/opt）下面，使用相对路径或者绝对路径均可，下面的命令使用绝对路径
tar -zxvf kafka_2.11-2.3.0.tgz -C /opt
（4）给kafka_2.11-2.3.0 文件重命名为kafka
mv kafka_2.11-2.3.0 kafka
（5）配置环境变量，编辑 /etc/profile 文件，在文件最后添加 kafka 路径
vim /etc/profile
export KAFKA_HOME=/opt/kafka
export PATH=$KAFKA_HOME/bin:$PATH
（6）使环境变量生效
source /etc/profile
（7）切换到 cd /opt/kafka/config 目录下
cd /opt/kafka/config
（8）修改kafka的配置文件 server.properties
vim server.properties
修改内容如下：
#broker的全局唯一编号，不能重复
broker.id=0
#删除topic功能
delete.topic.enable=true
#配置连接Zookeeper集群地址
zookeeper.connect=master:2181,slave1:2181,slave2:2181
（9）由于slave1节点也需要安装 kafka，因此可以先将master节点的 /opt/kafka 文件和 /etc/profile 文件拷贝到slave1的相同路径下
scp -r /opt/kafka root@slave1:/opt
scp /etc/profile root@slave1:/etc
（10）由于slave2节点也需要安装 kafka，因此可以先将master节点的 /opt/kafka 文件和 /etc/profile 文件拷贝到slave2的相同路径下
scp -r /opt/kafka root@slave2:/opt
scp /etc/profile root@slave2:/etc
以下操作在 slave1 节点进行
（11）切换到 /opt/kafka/config目录下
cd /opt/kafka/config
（12）将 server.properties 文件中的broker.id=0 修改为broker.id=1（master对应的编号是0、slave1对应的编号是1，slave2对应的编号是2）
vim server.properties
修改内容如下：
broker.id=1
以下操作在 slave2 节点进行
（13）切换到 /opt/kafka/config目录下
cd /opt/kafka/config
（14）将 server.properties 文件中的broker.id=0 修改为broker.id=2（master对应的编号是0、slave1对应的编号是1，slave2对应的编号是2）
vim server.properties
修改内容如下：
broker.id=2
以下操作在 master 节点进行
（15）启动kafka集群
kafka-server-start.sh -daemon /opt/kafka/config/server.properties
以下操作在 slave1 节点进行
（16）启动kafka集群
先使slave1节点上的环境变量生效：
source /etc/profile
然后再启动集群：
kafka-server-start.sh -daemon /opt/kafka/config/server.properties
以下操作在 slave2 节点进行
（17）启动kafka集群
先使slave2节点上的环境变量生效：
source /etc/profile
然后再启动集群：
kafka-server-start.sh -daemon /opt/kafka/config/server.properties
以下操作在 master 节点进行
（18）查看master节点的kafka进程是否启动
jps
以下操作在 slave1 节点进行
（19）查看slave1节点的kafka进程是否启动
jps
以下操作在 slave2 节点进行
（20）查看slave2节点的kafka进程是否启动
jps
到此就安装结束了
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！