步骤 1. 介绍
要在 Windows 操作系统上运行 Apache Kafka，您需要下载、安装并设置 Java、ZooKeeper 和 Apache Kakfa。设置好 Apache Kafka 后，我们将运行一些命令，在 Kafka 上的测试主题上生成和使用一些消息，以确保 Apache Kafka 正常运行。
步骤2.下载文件
Upzip 和文本编辑器工具
- 如果您的 Windows 系统尚未安装 7-zip，建议您从 ( Download ) 下载 7-zip。如果您的系统是 64 位 x64，您可以从 ( https://www.7-zip.org/a/7z1900-x64.exe )下载 exe 安装程序。
- 还建议您从（https://notepad-plus-plus.org/downloads/）下载文本编辑器 Notepad++
JRE下载
- 您可以根据您的 CPU 架构从 Oracle 网站（ Java Downloads | Oracle ）下载 Java 运行时。
ZooKeeper下载
Kafka 下载
- 您可以从 Apache 网站 ( http://kafka.apache.org/downloads.html )下载 Apache Kafka
以下是我的下载列表。
步骤 3. 安装 7zip 和 Notepad plus plus
您可以直接运行可执行安装程序（例如“7z1900-x64.exe”和“npp.7.8.8.Installer.x64.exe”）
步骤 4.安装 Java 运行时
您可以运行 JRE 安装程序（例如“jre-8u271-windows-x64.exe”），并将 Java 安装在其默认安装文件夹（例如“C:\Program Files\Java\jre1.8.0_271”）。安装完成后，您需要进行以下设置：
- JAVA_HOME的环境变量打开“控制面板”->“系统”->“高级系统设置”->“环境变量”->“系统变量”（“新建”）：
| 物品 | 价值 |
|---|---|
| 变量名 | JAVA_HOME |
| 变量值 | Java 安装文件夹（例如“C:\Program Files\Java\jre1.8.0_271”） |
- 将 Java 路径添加到“Path”变量中 选择“系统变量”部分的“Path”，然后点击“编辑...”按钮添加 Java 路径。在弹出的“编辑环境变量”窗口中，点击“新建”按钮，添加：
%JAVA_HOME%\bin
步骤 5.安装 ZooKeeper
- 使用 7zip 解压 ZooKeepr 的安装文件（例如“apache-zookeeper-3.6.2-bin.tar.gz”）。您需要解压两次才能获得原始文件。
- 完全解压后，您将有一个类似以下文件夹：C:\temp\KafkaDownloads\apache-zookeeper-3.6.2-bin.tar\apache-zookeeper-3.6.2-bin\apache-zookeeper-3.6.2-bin
- 将解压后的bin文件夹移动到C:下，并重命名为：C:\zookeeper-3.6.2，然后你就会看到：
- 将“C:\zookeeper-3.6.2\conf\zoo_sample.cfg”重命名为“C:\zookeeper-3.6.2\conf\zoo.cfg”
- 在“C:\zookeeper-3.6.2”下添加子文件夹“data”
- 使用 Notepad++ 编辑“C:\zookeeper-3.6.2\conf\zoo.cfg”为：
dataDir=C:/zookeeper-3.6.2/data
- 与上述 Java 安装类似，
- 向系统变量中添加“ZOOKEEPER_HOME”变量：
| 物品 | 价值 |
|---|---|
| 变量名 | ZOOKEEPER_HOME |
| 变量值 | C:\zookeeper-3.6.2 |
2.在系统变量“Path”中添加“%ZOOKEEPER_HOME%\bin”新条目
- 通过以下方式启动 ZooKeeper
- 在搜索区域（左下方）输入“cmd”
- 在命令行中输入
cd c:\zookeeper-3.6.2\bin
3.输入“zkserver”，你会看到：
步骤 6.安装并设置 Kafka
- 使用 7zip 解压 Kafka 安装文件（例如“kafka_2.13-2.7.0.tgz”）。您需要解压两次才能获得原始文件。
- 完全解压后，您将看到如下文件夹：C:\temp\KafkaDownloads\kafka_2.13-2.6.0\kafka_2.13-2.6.0\kafka_2.13-2.6.0
- 将解压后的文件夹移动到C:，并重命名为：C:\kafka，你会看到：
- 创建新的子文件夹 C:\kafka\kafka-logs
- 编辑 C:\kafka\config\server.properties，使用新值修改以下行：
log.dirs=c:/kafka/kafka-logs
- 如果您计划在本地计算机上使用其他默认设置运行 Kafka，那么您就可以开始了，否则，您可以使用正确的 IP 地址和自定义端口号更改以下默认设置：zookeeper.connect=localhost:2181。
- 打开一个新的命令提示符，然后：
1.类型：
cd c:\kafka, and press enter
2.然后按“Enter”，并输入：
.\bin\windows\kafka-server-start.bat .\config\server.properties
，然后按回车键，您将看到：
3.现在您已完成 Apache Kafka 的安装和设置，并且 Kafka 服务器已启动运行。
步骤 7.测试 Apache Kafka
-
创建一个名为“StudentImport”的主题
1.打开一个新的命令提示符，然后输入：cd c:\kafka\bin\windows，按回车键
2.类型：
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic StudentImport
3.至此，“StudentImport”已成功创建。如下所示：
-
为 Kafka 服务器创建生产者
1.打开一个新的命令提示符（称为生产者命令窗口“P”），然后输入：cd c:\kafka\bin\windows，按回车键
2.类型：
kafka-console-producer.bat --broker-list localhost:9092 --topic StudentImport
-
创建 Kafka 服务器的消费者
1.打开一个新的命令提示符（称为消费者命令窗口“C”），然后输入：cd c:\kafka\bin\windows，按回车键
2.类型：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic StudentImport
-
测试消息通信
- 在生产者命令窗口“P”（见上文）中输入：“你好，是春仁”，并回车后，在消费者命令窗口“C”（见上文）中就会看到显示“你好，是春仁”的消息。
- 在生产者命令窗口“P”中，当您输入：“我们将很快导入学生名册。”并按回车键时，在消费者命令窗口“C”中，您将看到显示消息“我们将很快导入学生名册。”。
- 参见以下结果： 在生产者命令窗口“P”中：
在消费者命令窗口“C”中：
恭喜！您已在 Windows 10 上成功设置Apache Kafka 。
如果您喜欢此文章，请收藏、点赞、评论，谢谢，祝您快乐每一天。