一、下载地址

http://kafka.apache.org/downloads.html

二、 zookeeper安装教程

https://blog..net/weixin_43205308/article/details/130426019

三、解压

这里使用的是kafka_2.12-3.0.0.tgz

tar -zvxf kafka_2.12-3.0.0.tgz

四、修改配置

进入到安装路径的config文件夹下

vim config/server.properties

这个每一台kafka节点都要修改(broker),且得保持不一样

路径默认使用的是临时路径，肯定要改，不然会造成数据丢失，根据自己情况配置，我是配置到我的安装路径

修改zookeeper连接地址，根据自己情况配置 分发给其他节点，记得修改broker.id=0

五、配置环境变量

vim /etc/profile.d/my_env.sh

记得source一下，和分发到其他节点

六、编写启动脚本

vim /$KAFKA_HOME/bin/kf.sh

#! /bin/sh
case $1 in
"start"){
          
   
        for i in hadoop100 hadoop101 hadoop102
        do
                echo "-----启动 $i KAFKA-----"
                ssh $i "$KAFKA_HOME/bin/kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties"
        done
};;
"stop"){
          
   
        for i in hadoop100 hadoop101 hadoop102
        do
                echo " --------停止 $i Kafka-------"
                ssh $i "$KAFKA_HOME/bin/kafka-server-stop.sh "
        done
};;
esac

赋予权限

chmod 777 kf.sh

七、启动

kf.sh start

八、关闭集群

kf.sh stop

启动成功