接前文zookeeper集群搭建，三台服务器IP仍然为：host_0、host_1、host_2
1、创建kafka安装目录
mkdir /home/lc/application/kafka
2、下载、解压2.8版本
wget https://archive.apache.org/dist/kafka/2.8.0/kafka_2.12-2.8.0.tgz tar -zxvf kafka_2.12-2.8.0.tgz
3、修改配置文件
vim kafka_2.12-2.8.0/config/server.properties #一个kafka节点就是一个broker.id，保证唯一性，三台服务器可分别设置为0,1,2 broker.id=1 #内网通讯地址 listeners=PLAINTEXT://当前服务器IP:9092 #数据存放路径 log.dirs=/home/lc/application/kafka/kafka-logs #zk地址 zookeeper.connect=host_0:2181,host_1:2181,host_2:2181
4、配置环境变量
vim /etc/profile # kafka env export KAFKA_HOME=/home/lc/application/kafka/kafka_2.12-2.8.0 export PATH=$PATH:$KAFKA_HOME/bin source /etc/profile # 检测环境变量是否配置成功 echo $KAFKA_HOME
5、创建重启脚本
cat </home/lc/application/kafka/kafka_2.12-2.8.0/bin/kafka-restart.sh #!/bin/bash kafka-server-stop.sh nohup kafka-server-start.sh /home/lc/application/kafka/kafka_2.12-2.8.0/config/server.properties >> /home/lc/application/kafka/nohup.out 2>&1 & EOF chmod +x kafka-restart.sh
7、查看安装是否正常
sh kafka-console-consumer.sh --bootstrap-server 服务器IP:9092 --topic kafka-topic
如果安装正常不会输出信息
