一、*Kafka环境配置*
1、上传安装包到/export/server/路径并解压
cd /export/server
rz
tar -zxvf kafka_2.11-2.0.0.tgz
2、修改配置文件
(1)进入配置文件目录
cd /export/server/kafka_2.11-2.0.0/config
(2)编辑配置文件
–vim server.properties
broker.id=0 从0开始,依次增加(0,1,2,3,4…),每台不能重复
将Listeners = plaintext://:9092改成:Listeners = plaintext://node1:9092
#数据存储的目录
log.dirs=/export/server/data/kafka-logs
#默认分区数
Num.partitions = 1
—-Log retention policy—-
数据保留策略 168/24=7,1073741824/1024=1GB,300000ms = 300s = 5min(超过了删掉)
#指定 zk 集群地址
zookeeper.connect=node1:2181,node2:2181,node3:2181
3、分发kafka
cd /export/server/
scp -r /export/server/kafka_2.11-2.0.0/ node2:$PWD
scp -r /export/server/kafka_2.11-2.0.0/ node3:$PWD
(注意:分发完后需修改node2,node3中的server.properties文件)
node2
node3
4、配置环境变量
vi /etc/profile(将以下内容添加到profile文件中,三台虚拟机都需要)
export KAFKA_HOME=/export/server/kafka
export PATH=$PATH:$KAFKA_HOME/bin
#重新加载环境变量
source /etc/profile
\1. 启动kafka