欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

windows 环境下安装 Kafka

程序员文章站 2024-01-12 12:55:34
...

一、安装JDK

因本地基本上都已安装好JDK,所以此步略过,直接打开cmd,键入 "java -version"命令查看当前系统的 Java 版本。
windows 环境下安装 Kafka
二、安装ZooKeeper

  1. 下载安装包。
    下载地址:http://zookeeper.apache.org/releases.html#download
    作者下载的是:apache-zookeeper-3.5.7-bin.tar.gz
    高版本的zookeeper,一般会有2个不同的包,如:apache-zookeeper-3.6.0.tar.gzapache-zookeeper-3.6.0-bin.tar.gz,使用带 bin 的二进制版本,否则在启动 zookeeper 时可能会报 “找不到或无法加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain” 错误。

  2. 解压并进入 ZooKeeper 的 conf 目录,将 zoo_sample.cfg 重命名为 zoo.cfg。
    作者的目录:D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin\conf

  3. 打开 zoo.cfg 文件,做如下修改。
    修改:dataDir=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin\data
    添加:dataLogDir=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin\logs
    添加:admin.serverPort=8888(PS:因在后续启动时报 8080 端口占用,所以修改端口为8888)

  4. 添加系统变量
    ZOOKEEPER_HOME=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin

  5. 编辑 path 系统变量,在其后添加 “;%ZOOKEEPER_HOME%\bin;”

  6. 打开 cmd,输入 “zkServer”,运行 Zookeeper,命令行提示如下图所示,则说明本地 Zookeeper 启动成功。
    windows 环境下安装 Kafka
    cmd 窗口不要关闭,继续安装 kafka。

三、安装并运行 kafka

  1. 下载安装文件: http://kafka.apache.org/downloads.html,作者下载的是 kafka_2.11-2.4.0.tgz。
  2. 将文件解压到 D 盘根路径。
  3. 进入 D:\kafka_2.11-2.4.0\config 目录,文本编辑器打开 server.properties,修改 log.dirs=D:\kafka_2.11-2.4.0\logs
  4. 进入 D:\kafka_2.11-2.4.0 目录,shift + 右键,在此处打开命令窗口,输入如下命令
.\bin\windows\kafka-server-start.bat .\config\server.properties

回车后出现

[2020-04-09 16:55:29,122] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)

则说明启动完毕。

PS:在键入上述命令时,作者出现过如下所示的错误。
windows 环境下安装 Kafka
起初安装路径较深,后改为了D盘根路径后错误解决。

窗口不要关闭,进入测试环节。

四、测试 kafka

  1. 创建 topic。
    在 D:\kafka_2.11-2.4.0\bin\windows 路径下打开 cmd 窗口,创建一个主题 test,命令如下:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

结果如下图所示:
windows 环境下安装 Kafka

  1. 打开一个 PRODUCER。
    在 D:\kafka_2.11-2.4.0\bin\windows 路径下打开 cmd 窗口,键入如下命令:
kafka-console-producer.bat --broker-list localhost:9092 --topic test
  1. 打开一个 CONSUMER。
    在 D:\kafka_2.11-2.4.0\bin\windows 路径下打开 cmd 窗口,键入如下命令:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
  1. 在 Producer 控制台窗口输入消息,在消息输入过后,很快 Consumer 窗口就会显示出 Producer 发送的消息,如下图所示。
    windows 环境下安装 Kafka
    windows 环境下安装 Kafka
    至此,Kafka 运行环境的搭建就完成了。