原文:

https://medium.com/@shaaslam/installing-apache-kafka-on-windows-495f6f2fd3c8

第一步:

在Windows上安装Apache ZooKeeper(https://medium.com/@shaaslam/installing-apache-zookeeper-on-windows-45eda303e835)

使用7-Zip下载并提取Apache Zookeeper，网址为：http: //zookeeper.apache.org/releases.html#download

JRE是运行Apache Zookeeper所必需的。

在撰写本文时，zookeeper的稳定版本为3.4.9。

您可以在任何地方下载和解压缩该文件，但出于本指南的考虑，我假设将zookeeper提取到C：\ Tools \

说明：

将C：\ Tools \ zookeeper-3.4.9 \ conf中的“ zoo_sample.cfg”复制并重命名为“ zoo.cfg”

在zookeeper文件夹中创建数据目录。

使用记事本或notepad ++等任何文本编辑器查找并编辑dataDir = /tmp/zookeeper到C:\\Tools\\zookeeper\\zookeeper-3.4.9\\data。（将zookeeper版本更改为您的版本）

dataDir = C:\\Tools\\zookeeper\\zookeeper-3.4.9\\data

在系统环境变量中添加条目。

添加系统变量ZOOKEEPER_HOME = C:\Tools\zookeeper-3.4.9

编辑名为“ Path”的系统变量，并将其附加在最后的;％ZOOKEEPER_HOME％\ bin;中。

打开命令提示符，然后键入zkserver。

zkserver将在默认端口2181上启动zookeeper，您可以在zoo.cfg文件中更改默认端口

第二步:

从此处(https://kafka.apache.org/)下载并解压缩Apache Kafka 。

设置Apache Kafka

1. 转到Apache Kafka中的config文件夹，然后使用任何文本编辑器编辑“server.properties” 。

2. 在“=/tmp/kafka-logs” 之后找到log.dirs并拒绝，直到 “=C:\\Tools\\kafka_2.10–0.10.1.1\\kafka-logs ” （更改您的版本号）。

保持其他设置不变。如果您的Apache Zookeeper在其他服务器上，则更改“zookeeper.connect”属性。

默认情况下，Apache Kafka将在端口9092上运行，而Apache Zookeeper将在端口2181上运行。

运行Apache Kafka

打开命令提示符，然后转到您的Apache Kafka目录，然后运行以下命令。

.\bin\windows\kafka-server-start.bat .\config\server.properties

在命令提示符上运行的Apache Kafka

一切顺利，Apache Kafka已启动并在端口9092上运行。

在Apache Kafka中创建主题，消费者和生产者

创建主题

1. 打开命令提示符，然后转到Apache Kafka安装目录。

2. 转到\bin\windows 目录。

3. 运行以下命令。

kafka-topics.bat — create — zookeeper localhost:2181 — replication-factor 1 — partitions 1 — topic sql-insert

您将看到输出。

创建主题“ sql-insert”。

创建消费者和生产者

1. 打开命令提示符，然后转到Apache Kafka安装目录。

2. 转到\bin\windows目录。

运行以下命令以启动生产者。

kafka-console-producer.bat —代理列表localhost:9092—主题 sql-insert
broker-list参数将要连接的代理指定为<node_address:port> —即 localhost:9092。

1. 再次打开命令提示符，然后转到Apache Kafka安装目录。

2. 转到\bin\windows目录。

3. 运行以下命令以启动使用者。

kafka-console-consumer.bat -bootstrap-server localhost:2181 -topic sql-insert

生产者和消费者在命令提示符上运行

通过在不同的终端中运行所有四个组件（动物园管理员，经纪人，生产者和消费者），您将能够从生产者的终端输入消息，并看到它们出现在订阅的消费者的终端中。如果一切正常，您将能够推送并查看消息。

恭喜你！您的Apache Kafka设置已完成。

/-----------------------------------------------------------------------------------/