Apache Kafka系列(二)----Windwos下搭建Kafka环境

末蓝、 2022-06-07 11:51 177阅读 0赞

**(一)、配置Zookeeper**

Kafka的运行依赖于Zookeeper，所以在运行Kafka之前我们需要安装并运行Zookeeper，具体步骤如下:

1.1 下载安装文件：[ http://mirror.bit.edu.cn/apache/zookeeper/ ][http_mirror.bit.edu.cn_apache_zookeeper]

![20171020143644165][]

这里选择的是3.5.2版本。

**1.2 解压文件（本文解压到 D:\\kafka） **

![20171020143753255][]

**1.3 打开D:\\kafka\\zookeeper-3.5.2-alpha\\zookeeper-3.5.2-alpha\\conf，把zoo\_sample.cfg重命名成zoo.cfg **

![20171020143846351][]

**1.4 从文本编辑器里打开zoo.cfg **

![20171020143914048][]

**1.5 修改dataDir和dataLogDir保存路径 **

dataDir=D:\\data\\logs\\zookeeper   
dataLogDir=D:\\data\\logs\\zookeeper

![20171020144011082][]

**(二)、配置Kafka**

2.1 下载安装文件： [ http://kafka.apache.org/downloads.html][http_kafka.apache.org_downloads.html]

![20171020144325654][]

**2.2 解压文件（本文解压到 D:\\kafka） **

**2.3 打开D:\\kafka\\kafka\_2.12-0.11.0.1\\kafka\_2.12-0.11.0.1\\config\\server.properties 、修改log.dirs**

![20171020144525082][]

**(三)、启动Zookeeper与Kafka**

**3.1、进入Zookeeper的D:\\kafka\\zookeeper-3.5.2-alpha\\zookeeper-3.5.2-alpha\\bin目录下、打开cmd然后执行zkServer.cmd 文件、如下则运行成功:**

![20171020144930019][]

**3.2、进入KafKa的D:\\kafka\\kafka\_2.12-0.11.0.1\\kafka\_2.12-0.11.0.1\\bin\\windows目录下、打开cmd然后执行以下命令**

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

如下则运行成功:

![20171020150119306][]

**(四)、测试Kafka**

**4.1、创建topics **

在D:\\kafka\\kafka\_2.12-0.11.0.1\\kafka\_2.12-0.11.0.1\\bin\\windows文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口

.\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

![20171020150415296][]

**4.2、创建一个Producer **

在D:\\kafka\\kafka\_2.12-0.11.0.1\\kafka\_2.12-0.11.0.1\\bin\\windows文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口

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

![20171020150535857][]

**4.3、创建一个Consumer **

在D:\\kafka\\kafka\_2.12-0.11.0.1\\kafka\_2.12-0.11.0.1\\bin\\windows文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口

.\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

![20171020150654406][]

注意：以上打开的窗口不要关闭

然后就可以在Producer控制台窗口输入消息了。在消息输入过后，很快Consumer窗口就会显示出Producer发送的消息：

![20171020151055881][]

[http_mirror.bit.edu.cn_apache_zookeeper]: http://mirror.bit.edu.cn/apache/zookeeper/
[20171020143644165]: /images/20220607/27b58d1586a34033b67e50a47a92f0ab.png
[20171020143753255]: /images/20220607/cd25b07b528240a38e3a6e92e3c15a21.png
[20171020143846351]: /images/20220607/31d546191067401682d16cce2d3d750c.png
[20171020143914048]: /images/20220607/a93aeca815834859afaf5dc0540860d5.png
[20171020144011082]: /images/20220607/6249b1cc32e74d94899e54b66183f3ad.png
[http_kafka.apache.org_downloads.html]: http://kafka.apache.org/downloads.html
[20171020144325654]: /images/20220607/a9237db5d2f24cc4a22d82f6e08f1572.png
[20171020144525082]: /images/20220607/f38579d7f8104e9ab1b1d1ce80ac12f3.png
[20171020144930019]: /images/20220607/f620223b6529451f9700e383b8988558.png
[20171020150119306]: /images/20220607/675c4fac024642c1a845c90e22daa524.png
[20171020150415296]: /images/20220607/4861f1da9a0d444d80c00c0887613693.png
[20171020150535857]: /images/20220607/a9b3d1b163684ba1bc00ccbe0429f96a.png
[20171020150654406]: /images/20220607/1f64412525b346f7b4d0b2481aae7588.png
[20171020151055881]: /images/20220607/950ae4d48c8b48299c444da70d6a4a07.png