Windows系统下快速启动Kafka

我会带着你远行 2024-03-26 16:18 77阅读 0赞

#### 目录 ####

*  一、获取Kafka
 *  二、启动KAFKA环境
 *   *  2.1 启动zookeeper服务
     *  2.2 启动Kafka服务
     *  2.3 验证 Kafka 服务是否正常工作
 *  三、操作Kafka
 *   *  3.1 创建 Kafka 主题（Topic）
     *  3.2 将一些事件写入主题（Topic）
     *  3.3 读取事件

## 一、获取Kafka ##

[下载][Link 1]最新的 Kafka 版本并解压：

![Kafka解压后文件夹内容][Kafka]  
打开配置文件：`/config/server.properties`，进行相应配置修改。

注意：`zookeeper.connect=localhost:2181`，默认zookeeper为本机端口号2181，如果要以其它ip和端口上的zookeeper服务为环境基础，需要在此进行配置。

## 二、启动KAFKA环境 ##

`注意：您的本地环境必须安装 Java 8+。`

### 2.1 启动zookeeper服务 ###

启动zookeeper服务，如果没有，请前往[下载][Link 2]。

下载后，打开zookeeper安装目录，进入`bin`文件夹，双击`zkServer.cmd`启动zookeeper服务。

![zookeeper文件夹内容][zookeeper]

成功启动后，以下页面不要关闭

![zookeeper启动成功页面][zookeeper 1]

### 2.2 启动Kafka服务 ###

进入到Kafka安装目录：

![Kafka目录][Kafka 1]

勾选`bin`文件夹，按下Shift+右键，选择“选择在此处打开 Powersheel 窗口”

![在这里插入图片描述][d4e47a213e6040ecb7d05037a66e9a1f.png]

输入命令: `start cmd`，Enter回车

![在这里插入图片描述][73a68f5137b64b12b629396bdb0d24c6.png]

弹出命令窗口：

![在这里插入图片描述][228863dbff8149e4b9449281b610fa34.png]

`提示：除了上面这种启动命令窗口方式，还有一种更为快捷的方式：在对应的文件夹目录框内输入 cmd 后按回车键，也会直接弹出命令窗口。`

通过运行`D:\Develop\kafka_2.13-3.4.0\bin\windows\`文件夹下的 `kafka-server-start.bat` 脚本文件并指定配置文件来启动Kafka服务

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

![在这里插入图片描述][df3b683893814197987a96615c8d7184.png]

启动成功后，页面也不要关闭

![在这里插入图片描述][3b613ce4692042b3b2f02773ee95c112.png]

### 2.3 验证 Kafka 服务是否正常工作 ###

重新打开一个命令窗口，并使用以下命令验证 Kafka 是否正常工作

.\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

![在这里插入图片描述][313a3ae72c674555a59393a932f3a87e.png]

如果能够输出 Kafka 中所有的主题列表，则表示 Kafka 正常工作。

## 三、操作Kafka ##

### 3.1 创建 Kafka 主题（Topic） ###

例如，创建一个主题（Topic）为 `quick_start_topic` 的主题：

.\windows\kafka-topics.bat --create --topic quick_start_topic --bootstrap-server localhost:9092

![在这里插入图片描述][c21bded59eaf4256ae050e9228694d2e.png]

创建完之后，可以使用以下命令查看刚创建的主题的分区计数等详细信息：

.\windows\kafka-topics.bat --describe --topic quick_start_topic --bootstrap-server localhost:9092

![在这里插入图片描述][8c2c3a12bb5e46cdb9cddc58d26466db.png]

### 3.2 将一些事件写入主题（Topic） ###

Kafka 客户端通过网络与 Kafka 代理通信以写入（或读取）事件。一旦收到，代理将以持久和容错的方式存储事件，只要您需要——甚至永远。

运行控制台生产者客户端以将一些事件写入您的主题。默认情况下，您输入的每一行都会导致一个单独的事件被写入主题。

.\windows\kafka-console-producer.bat --topic quick_start_topic --bootstrap-server localhost:9092

![在这里插入图片描述][f01e870a7e0746e7936fec3cd47c4c2b.png]  
`Ctrl-C` 可以随时停止生产者客户端。

### 3.3 读取事件 ###

打开另一个终端会话并运行控制台消费者客户端以读取刚刚创建的事件：

.\windows\kafka-console-consumer.bat --topic quick_start_topic --from-beginning --bootstrap-server localhost:9092

![在这里插入图片描述][f6ff5674bca1454388f01783ebd14a31.png]  
然而，在读取`quick_start_topic`主题内的事件时，由于之前生产者写入了一条中文事件。在消费者客户端读取时，出现了中文乱码。

事件持久存储在 Kafka 中，所以它们可以被任意多次读取，并且可以被任意多的消费者读取。

[Link 1]: https://www.apache.org/dyn/closer.cgi?path=/kafka/3.4.0/kafka_2.13-3.4.0.tgz
[Kafka]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/bc870f7ebaee444ab045cd851b81273f.png
[Link 2]: https://zookeeper.apache.org/releases.html#download
[zookeeper]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/fe56a6fbec96479fba60633051b08f53.png
[zookeeper 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/9bacbd632a2a412e90b8d9e1ea24672e.png
[Kafka 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/96285120ef0546d4b0f58d9e03ec14af.png
[d4e47a213e6040ecb7d05037a66e9a1f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/4f7e63bc40cc45718acf0820eb205e0f.png
[73a68f5137b64b12b629396bdb0d24c6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/50b76521de6b4f73be801220326e390b.png
[228863dbff8149e4b9449281b610fa34.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/eed3d6adc202403fafdc06fd7629adef.png
[df3b683893814197987a96615c8d7184.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/c5b7fb8cd22b4b889a10c77fcf500115.png
[3b613ce4692042b3b2f02773ee95c112.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/542e06f1fd504f90baf019b1e48c0092.png
[313a3ae72c674555a59393a932f3a87e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/bfe87ef3134c4e799e6049945ee39017.png
[c21bded59eaf4256ae050e9228694d2e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/fa1f9b4b57e34ce39b5b53b61f73d6aa.png
[8c2c3a12bb5e46cdb9cddc58d26466db.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/556100321dd842de81bd0d591d247c01.png
[f01e870a7e0746e7936fec3cd47c4c2b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/9818c507199e474891d32ed9c87f85f9.png
[f6ff5674bca1454388f01783ebd14a31.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/814188788f864bf4b27c11d48628e58d.png