1.解压缩安装包

[atguigu@hadoop102 software]$ tar -zxvf kafka_2.11 0.11.0.0.tgz -C
/opt/module

2.创建logs文件夹: kafka根目录下

3.修改配置文件

vim /config/server.properties

'broker的全局唯一编号，不能重复'
broker.id=0
'删除 topic 功能使能'
delete.topic.enable=true
'处理网络请求的线程数量'
num.network.threads=3
'用来处理磁盘 IO 的现成数量'
num.io.threads=8
'发送套接字的缓冲区大小'
socket.send.buffer.bytes=102400
'接收套接字的缓冲区大小'
socket.receive.buffer.bytes=102400
'请求套接字的缓冲区大小'
socket.request.max.bytes=104857600
'kafka 运行日志存放的路径'
log.dirs=/opt/module/kafka/logs
'topic 在当前 broker 上的分区个数'
num.partitions=1
'用来恢复和清理 data 下数据的线程数量'
num.recovery.threads.per.data.dir=1
'segment文件保留的最长时间，超时将被删除'
log.retention.hours=168
'配置连接 Zookeeper 集群地址'
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181

4.配置环境变量

KAFKA_HOME

export KAFKA_HOME=/opt/module/kafka

export PATH=\$PATH:\$KAFKA_HOME/bin

5.其他机器修改broker.id: broker.id不得重复

6.启动

[atguigu@hadoop104 kafka]$ bin/kafka-server-start.sh -daemon
config/server.properties

7.关闭

[atguigu@hadoop102 kafka]$ bin/kafka-server-stop.sh stop