一、安装

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

  1. ln -s kafka-3.1.0-src kafka0

二、Zookeeper配置

当前下载的kafka程序里自带Zookeeper,可以直接使用其自带的Zookeeper建立集群,也可以单独使用Zookeeper安装文件建立集群。

1.单独使用Zookeeper安装文件建立集群

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
Last modification:October 14, 2022
如果觉得我的文章对你有用,请随意赞赏