Skip to main content

Windows安装 Kafka

通常使用kafka都是安装在linux系统的，但有时候为了方便学习和本地开发测试，我们手上又没有linux机器，就可以考虑直接在windows下安装一个kafka. 请看下面的安装步骤

第一步：下载安装包​

我们到官网 https://kafka.apache.org/downloads 下载安装包，我写这篇文章的时候，最新的版本是3.0.0。我下载的是 kafka_2.13-2.8.1.tgz 这个安装包。 下载后解压，我把文件解压到了 c:\soft目录下，大家可以根据自己的需要存放

第二步：运行 zookeeper.​

  1. 打开 windows 命令行，进入 c:\soft\kafka_2.13-2.8.1 目录
  2. 执行 bin\windows\zookeeper-server-start.bat config\zookeeper.properties 命令启动zookeeper 
C:\soft\kafka_2.13-2.8.1>bin\windows\zookeeper-server-start.bat config\zookeeper.properties

如果有错误，注意检查一下自己当前所在的目录。

第三步：运行 kafka-server​

  1. 打开 另一个 windows 命令行，进入 c:\soft\kafka_2.13-2.8.1 目录
  2. 执行 bin\windows\kafka-server-start.bat config\server.properties 命令启动kafka-server
C:\soft\kafka_2.13-2.8.1>bin\windows\kafka-server-start.bat config\server.properties

到此为止，在windows下安装和启动kafka就算结束了，如果要验证安装是否正确，可以使用kafka客户端测试一下。

测试验证​

接下来我们创建一个topic.

C:\soft\kafka_2.13-2.8.1>bin\windows\kafka-topics.bat --bootstrap-server 127.0.0.1:9092 --create --topic test-topic

控制台打印出

Created topic test-topic.

这就说明 topic 创建成功了。

小插曲​

一开始我用的是kafka3.0.0的版本，我在执行这个命令时，报了一个错：

[2021-12-02 09:02:37,380] ERROR Failed to create or validate data directory C:\tmp\kafka-logs (kafka.server.LogDirFailureChannel)
java.nio.file.AccessDeniedException: C:\tmp
        at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83)
        at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
        at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
        ...
        at kafka.server.KafkaServer.startup(KafkaServer.scala:254)
        at kafka.Kafka$.main(Kafka.scala:109)
        at kafka.Kafka.main(Kafka.scala)

按错误信息看,是一个目录没有权限。后来给目录加上了权限，还是报这个错。在网上查有人说是数据有问题，我就把 c:\tmp下的目录 全删了，再重启zookeeper 和 kafka-server。也还是不行，再查了一下发现有人说是版本有问题。3.0.0的版本会报错，用2.8.1就好了。我试了一下，果然如此。

最后说明一下，windows下使用kafka建议还是仅供本地开发测试。生产还是使用linux系统安装kafka。