部署Kafka需要先安装和配置Zookeeper。Zookeeper是一个开源的分布式协调服务,Kafka使用Zookeeper来存储元数据和协调集群中的各个节点。Kafka依赖于Zookeeper来管理和维护其集群状态信息,包括主题(topics)、分区(partitions)和消费者组(consumer groups)等。因此,在部署Kafka之前,需要先安装、配置和启动Zookeeper ### # kafka-xx-yy xx是scala版本,yy是kafka版本 (scala是基于jdk开发的所以需要安装jdk环境) kafka下载地址:https://kafka.apache.org/downloads 这里我们使用kafka_2.13-2.8.0版本 可以直接去我的百度网盘下载: 链接: https://pan.baidu.com/s/1wvY4G7AuCNEszIhgkNnY-Q 提取码: x26h ### # zookeeper ### Apache软件基金会的一个软件项目,它为大型分布式计算提供开源的分布式配置服务、同步服务和命名注册 链接: https://pan.baidu.com/s/1lVFgSNxU0RPtpGe5AFZ5Ug 提取码: 8sjj ### # jdk1.8 ### 链接: https://pan.baidu.com/s/1ish5N6XJ9XOoX7xoErrI-Q 提取码: b53h ### # 安装jdk1.8 ![](https://img.kancloud.cn/dc/82/dc82620d4f1ff1e5c276a5b33637090d_806x667.png) ### 查看安装情况 `java -version` ### # 安装zookeeper ### 上传解压就不废话了 ### ![](https://img.kancloud.cn/24/c8/24c86fa20c24ce2faab0a75ce716b1f4_919x372.png) ### zookeeper默认端口号是2181 关闭防火墙或者阿里云开放该端口号 ### 启动zk 在bin目录里面有启动文件 `./bin/zkServer.sh start` ### # 安装kafka ### 上传解压就不废话了 ### ![](https://img.kancloud.cn/19/5e/195efa1f3b40b76810fe99cfaeae5611_1507x876.png) ### ![](https://img.kancloud.cn/1c/9b/1c9b2a725f2997f5878e6dc42a21cc27_1231x363.png) ### bin目录启动kafka ### `./kafka-server-start.sh ../config/server.properties &` ### bin目录停止kafka `./kafka-server-stop.sh` ### 这种启动方式如果直接启动信息会打印在控制台如果关闭窗口,kafka随之关闭 ### 所以我们可以守护进程方式启动 ### `./kafka-server-start.sh -daemon ../config/server.properties &` ###