目录
1、下载kafka
[kafka下载地址]
也可以自己通过[链接]选择合适的版本
或者通过百度网盘下载
链接:https://pan.baidu.com/s/1GGfd-YGZNqBiWv9qdDyYTQ
提取码:mm3g
2、上传服务器并解压
上传安装包到服务器/usr/local路径下
解压安装包
tar -zxvf kafka_2.13-3.1.0.tgz
重新命名
mv kafka_2.13-3.1.0 kafka
3、配置环境变量
echo 'export KAFKA_HOME=/usr/local/kafka' >> /etc/profile
echo 'export PATH=$PATH:$KAFKA_HOME/bin' >> /etc/profile
source /etc/profile
4、修改server.properties文件
cd /usr/local/kafka/config
vim server.properties
重点修改以下参数 (这里需要zookeeper单机或者集群,如果没有搭建zookeeper单机或者集群可以参考我前面文章搭建zookeeper单机或者集群)
# broker编号,保证每台机器值不同。第一台机器0,第二台机器1,第三台机器2
broker.id=0
# broker对外提供服务的入口地址 注意改为本机ip
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://本机IP:9092
# 存放消息日志文件 不要使用默认值,会丢失数据
log.dirs=/tmp/kafka/logs
# zookeeper集群地址
zookeeper.connect=A服务器IP:2181,B服务器器IP:2181,C服务器集群IP:2181
创建上面的日志路径
mkdir -p /tmp/kafka/logs
5、启动kafka
cd /usr/local/kafka/bin/
./kafka-server-start.sh -daemon ../config/server.properties
6、搭建kafka集群
在其他两台服务器上按照上面的方法安装kafka,注意修改server.properties时,broker.id分别改为1和2
broker.id=1
broker.id=2
分别启动上面两台服务器的kafka服务
7、查看每台服务器kafka是否启动成功
ps -ef | grep kafka
截图如下表示成功