Kafka的安装与配置

一、预备工作

要安装 Kafka 首先需要安装 Zookeeper 和 Scala

Zookeeper：Zookeeper在windows的安装与配置

Scala：Scala在windows的安装与配置

二、下载

官方的下载地址：https://kafka.apache.org/downloads

这两个任选一个下载，下载后解压到目标文件夹即可

三、配置

1. 在目录下新建空文件夹 logs

   

2. 修改 config 目录下的 server.properties 文件

   

3. 修改 server.properties 中 log.dirs 为刚刚新建的 logs 文件夹路径，注意路径的分隔符是 / 而不是 \

   

4. 修改监听端口，默认是注释掉的

   

5. 修改编码格式，避免出现乱码，可以先找一下有没有 producer.encoding，没有的话就新增一个，我就是新增的一条

   

6. 配置环境变量

   • 找到环境变量，直接进入后新建系统变量 KAFKA_HOME ，地址就是解压路径

     

   • 然后进入 path

     

   • 再新建环境变量 %KAFKA_HOME%\bin

     

四、启动

1. 需要先启动 zookeeper 的 zkServer.cmd

   

2. 进入 kafka 的安装路径，开启命令行输入如下命令：.\bin\windows\kafka-server-start.bat .\config\server.properties

   

   出现如下这样就算成功

   

五、验证

首先认识一下生产者和消费者脚本

这是启动停止和topic脚本

1. 创建和查看topic

   命令如下：

   #创建topics，--topic后为topic名称,--replication-factor为副本数量，partitions 为分区数量
   kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafkatest
    
   #查看所有的topics
   kafka-topics.bat --bootstrap-server localhost:9092 --list

   首先创建一个名叫 kafkatest 的 topic

   

   然后查看一下它

   

2. producer 发送消息

   使用如下命令向刚刚创建的 kafkatest 中发送消息

   kafka-console-producer.bat --broker-list localhost:9092 --topic kafkatest

   

3. consumer 接收消息

   使用如下命令接收消息

   kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafkatest --from-beginning

   可以发现当生产者发送消息时就可以接收到

   

六、遇到的问题

在启动 kafka 的时候会出现这样的问题：kafka启动输入行太长。 命令语法不正确。

这可能是因为文件太深了，比如我就删除了路径中的额外的 kafka 文件夹，别忘了还需要修改 server.properties 中的 log.dirs 和环境变量中的路径

参考文章：【Kafka】Windows下安装Kafka（全面）_windows安装kafka-CSDN博客