准备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