一、安装
kafka可以通过官网下载:https://kafka.apache.org/downloads
kafka根据Scala版本不同,又分为多个版本,我不需要使用Scala
,所以就下载官方推荐版本kafka_2.12-2.4.0.tgz
。
使用tar -xzvf kafka_2.12-2.4.0.tgz
解压
为了使用方便,可以创建软链接kafka
ln -s kafka-3.1.0-src kafka0
二、Zookeeper配置
当前下载的kafka程序里自带Zookeeper,可以直接使用其自带的Zookeeper建立集群,也可以单独使用Zookeeper安装文件建立集群。
1.单独使用Zookeeper安装文件建立集群
Zookeeper的安装及配置可以参考另一篇博客,里面有详细介绍
2.直接使用其自带的Zookeeper建立集群
kafka自带的Zookeeper程序脚本与配置文件名与原生Zookeeper稍有不同。
kafka自带的Zookeeper程序使用bin/zookeeper-server-start.sh
,以及bin/zookeeper-server-stop.sh
来启动和停止Zookeeper。
而Zookeeper的配制文件是config/zookeeper.properties
,可以修改其中的参数
(1) 启动Zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties