Mac及Linux环境下配置Kafka

准备Kafka

下载Kafka

💡这里以Kafka 3.5.0为例。Kafka的运行依赖Zookeeper,但由于现在的Kafka版本都内置了Zookeeper,因此无需额外配置。

前往Apache Kafka官网下载kafka_2.13-3.5.0.tgz。

解压Kafka

将下载的Kafka解压至安装目录,这里以/usr/local/为例:

sudo tar -zxvf kafka_2.13-3.5.0.tgz -C /usr/local/

修改配置文件

进入Kafka的配置文件目录下,以/usr/local/kafka_2.13-3.5.0/config为例。

server.properties文件中添加如下内容:

listeners = PLAINTEXT://localhost:9092
# 如果不填写advertised.listeners,则与listeners相同
advertised.listeners = PLAINTEXT://localhost:9092

运行Kafka

进入Kafka安装目录下,以/usr/local/kafka_2.13-3.5.0为例。

启动Zookeeper

执行如下命令启动Zookeeper:

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

启动Kafka

执行如下命令启动Kafka:

bin/kafka-server-start.sh -daemon config/server.properties

使用jps命令查看当前Java进程,如果出现了如下两个进程说明启动成功:

25713 Kafka
25327 QuorumPeerMain