1.下载安装包

官网 (opens new window)

本文章下载：kafka_2.13-2.5.0.tgz (opens new window)

解压：tar -zvxf kafka_2.13-2.5.0.tgz

2.配置Kafka

配置文件位置为conf/server.proprties

如何查看kafka的默认config配置？

cat kafka_2.13-2.5.0/config/server.properties |grep '^[a-z]'

3. 启动Zookeeper

• 安装可以参考文章:zookeeper安装 (opens new window)

• 也可以用kafka的bin中自带的启动zookeeper命令

首先启动 kafka需要依赖Zookeeper 服务，首先需要先启动Zookeeper服务:

bin/zookeeper-server-start.sh config/zookeeper.properties &
(使用bin/zookeeper-server-start.sh -daemon config/zookeeper.properties以守护进程启动)

执行命令启动以后通过jps检测是否启动成功

从上图看到启动后有个QuorumPeerMain，它就是Zookeeper集群的启动入口类，是用来加载配置启动QuorumPeer 线程的。

4. 启动kafka

注意：在启动kafka之前，我们需要更改server配置文件中的配置：

如果这里没有配置好，外界如java客户端是访问不了我们的kafka应用的。可参考：https://blog.csdn.net/weixin_43751248/article/details/124285603 (opens new window)

如果已经启动了Zookeeper服务，则直接运行下面的命令来启动或者停止Kafka服务:

#1、启动kafka服务命令:
bin/kafka-server-start.sh config/server.properties &
#2、停止kafka 服务则运行下面命令:
bin/kafka-server-stop.sh config/server.properties

因为kafka server也是一个java项目，所以用jps也可以看到对应的kafka进程

5. 测试

1. 创建一个名为message的topic，只是用单个分区和一个副本

bin/kafak-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic message

2. 查看topic命令

bin/kafka-topics.sh --list --zookeeper localhost:2181

3. 发送消息命令

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic message

4. 打开另一个终端进行消费

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic message --from-beginning