消息中间件kafka部署(一、使用kafka内置zookeeper组件部署kafka单节点服务) 消息中间件kafka部署(一、使用

今天来说一说消息中间件kafka的单节点部署，后续会有集群部署，使用外部zookeeper服务进行单节点部署以及集群部署的系列文章，想了解更多请关注笔者文集《kafka从零到应用》; 也欢迎各位大佬投稿笔者创建的专栏《kafka应用》；
1、Kafka官网下载安装包 http://kafka.apache.org/downloads.html

文章图片
官网提供了源码包（需自行编译）和编译好的可直接使用的安装包，本文采用的是编译好的。
2、将安装包上传至服务器并解压，如下图第一个是解压出来的，第二个是上传到服务器上的安装包（暂时忽略kafka-logs文件夹）。

文章图片
3、这一步开始进行配置。进入解压出来的目录

文章图片
kafka自带了zookeeper组件，单节点kafka服务我们可以使用自带的zookeeper组件。在config文件夹下找到zookeeper.properties打开内容如下

文章图片

dataDir为zookeeper的数据目录，可自定义；
clientPort为zookeeper监听的端口号;

如果想自定义可按照自己的规划进行配置，切记自定义文件夹必须存在，这里笔者采用默认数据，保存后接下来配置kafka的配置文件server.propertis

【消息中间件kafka部署(一、使用kafka内置zookeeper组件部署kafka单节点服务)】broker.idkafka节点的标识
advertised.listeners=PLAINTEXT://10.224.25.21:9092 配置监听,修改为本机ip
num.network.threads=3 处理网络请求的线程数量，默认
num.io.threads=8 用来处理磁盘IO的线程数量，默认
socket.send.buffer.bytes=102400 发送套接字的缓冲区大小，默认
socket.receive.buffer.bytes=102400 接收套接字的缓冲区大小，默认
socket.request.max.bytes=104857600 请求套接字的缓冲区大小，默认
zookeeper.connect=10.224.25.21:2181 zookeeper连接地址
log.dirs=/usr/local/kafka_2.11-1.0.0/log/kafkakafka的运行日志存放路径（此处笔者为方便管理采用自定义统一路径的方式，还记得第二部忽略的kafka-logs文件夹吗，对，就是他）
num.partitions=3topic 在当前broker上的分片个数，与broker保持一致
num.recovery.threads.per.data.dir=1用来恢复和清理data下数据的线程数量，默认
log.retention.hours=168segment文件保留的最长时间，超时将被删除，默认
log.roll.hours=168滚动生成新的segment文件的最大时间，默认

4、接下来该启动kafka服务了，
进入解压完之后的kafka目录下的bin文件夹,执行以下命令启动zookeeper

./zookeeper-server-start.sh config/zookeeper.properties

然后启动kafka

./kafka-server-start.sh config/server.properties
上面这种kafka启动方式在你退出之后会停止运行，所以我们需要以守护进程模式启动kafka，执行下面的命令
./kafka-server-start.sh –daemon config/server.properties &

到这里单节点的kafka就部署完了。
如有问题，欢迎各位大佬指正