一、安装JDK
安装JDK可以看过去写过的这篇文章:
Linux(centos 7.5)服务器安装JDK(1.8)
https://blog.csdn.net/lydms/article/details/95232577
二、安装zookeeper
安装JDK可以看过去写过的这篇文章:
Linux(centos 7.5)服务器安装Zookeeper
https://blog.csdn.net/lydms/article/details/109267035
三、安装kafka
1、下载地址
http://kafka.apache.org/downloads.html
2、创建文件安装目录
mkdir /usr/local/kafka
3、解压文件
tar -zxvf /root/kafka_2.11-0.11.0.0.tgz -C /usr/local/kafka
4、添加环境变量
打开/etc/profile 文件
vim /etc/profile
最后插入一下内容
#KAFKA_HOME export KAFKA_HOME=/usr/local/kafka/kafka_2.11-0.11.0.0 export PATH=$PATH:$KAFKA_HOME/bin
重新加载/etc/profile配置文件
source /etc/profile
5、kafka_2.11-0.11.0.0
目录下创建 logs 文件夹
cd /usr/local/kafka/kafka_2.11-0.11.0.0 mkdir logs
6、查看配置文件
cd config cat 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
7、启动 kafka
进入 kafka安装目录
cd /usr/local/kafka/kafka_2.11-0.11.0.0
启动 kafka
bin/kafka-server-start.sh config/server.properties
关闭 kafka
bin/kafka-server-stop.sh stop