原文: https://howtodoinjava.com/kafka/getting-started-windows-10/

学习在 Windows 10 上安装 Apache Kafka 并执行与 Kafka 和 Zookeeper 相关的启动服务器停止服务器脚本。 我们还将通过创建主题,向其生成少量消息,然后使用用户读取用 Kafka 编写的消息来验证 Kafka 的安装。

1. 先决条件

  • 需要 Java8 才能从 Kafka 网站运行最新下载。
  • Zookeeper (用于存储有关 Kafka 群集的元数据)也是必需的。 Kafka 首先内置了 Zookeeper。 但是建议在生产环境中单独安装 Zookeeper。 从其官方网站下载它。
  • Kafka 可以在任何操作系统上运行。 推荐使用 linux 操作系统。 使用 Windows,Kafka 有一些已知的错误。

本教程适用于初学者,并且不使用单独的 zookeeper 实例 - 保持简单,仅专注于 Kafka。

2. 下载并安装 Kafka

  • 官方网站下载 Kafka。 我今天下载了最新版本 2.5.0,文件名为“kafka_2.12-2.5.0.tgz”。

  • 将下载的文件复制到某个文件夹,然后使用tar命令将其解压缩。

    1. > tar -xzf kafka_2.12-2.5.0.tgz
  • 将提取的文件夹复制到所需位置。 我把它放在位置“E:\devsetup\bigdata\kafka2.5”中。
    安装几乎完成了!

3. 启动和关闭

要启动 Kafka,我们需要先启动 Zookeeper,然后再启动 Kafka。 我正在编写小的批处理文件,这些文件首先移至 Kafka 安装目录,然后在新的命令提示符窗口中执行命令。

3.1 启动 Zookeeper

要启动 Zookeeper,我们需要运行zookeeper-server-start.bat脚本并传递 zookeeper 配置文件路径。

  1. cd E:\devsetup\bigdata\kafka2.5
  2. start cmd /k bin\windows\zookeeper-server-start.bat config\zookeeper.properties

3.2 启动 Kafka

要启动 Kafka,我们需要运行kafka-server-start.bat脚本并传递 Broker 配置文件路径。

  1. cd E:\devsetup\bigdata\kafka2.5
  2. start cmd /k bin\windows\kafka-server-start.bat config\server.properties

3.3 关闭 Kafka

要停止 Kafka,我们需要运行kafka-server-stop.bat脚本。

  1. cd E:\devsetup\bigdata\kafka2.5
  2. start cmd /k bin\windows\kafka-server-stop.bat

3.4 关闭 Zookeeper

要停止 Zookeeper,我们需要运行zookeeper-server-stop.bat脚本。

  1. cd E:\devsetup\bigdata\kafka2.5
  2. start cmd /k bin\windows\zookeeper-server-stop.bat

不要使用CTRL+C命令停止 zookeeper 和 kafka。 始终使用上面的.bat文件或命令。 否则可能会发生数据损坏。

4. 验证 Kafka 安装

首先,使用上述脚本启动 Zookeeper 和 Kafka。

  • 打开一个新的命令提示符,然后创建一个新的 Kafka 主题。 ```java

    bin\windows\kafka-topics.bat —create —bootstrap-server localhost:9092 —replication-factor 1 —partitions 1 —topic test

//Output:

Created topic test.

  1. -
  2. 现在**列出所有主题**以验证创建的主题是否存在于此列表中。 在这一步,我们只有一个主题。
  3. ```java
  4. > bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092
  5. //Output:
  6. test
  • 现在列出所有主题,以验证创建的主题是否存在于此列表中。 在这一步,我们只有一个主题。 ```java

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

//Output:

test

  1. -
  2. **产生一些消息**并提交给`test`主题。 我添加了两个消息,即“`Hello`”和“`Kafka`”。
  3. ```java
  4. > bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test
  • 使用消息并提交到test主题。 ```java

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

//Output:

Hello Kafka ```

Apache Kafka – Windows 10 入门 - 图1

验证 Kafka 安装

5. 总结

在本教程中,我们学习了与 Zookeeper 一起安装 Kafka。 我们学会了启动和停止这两个服务器。 此外,我们通过创建主题,发布一些消息然后使用控制台用户脚本进行使用来验证安装。

需要注意的重要一点是,我们永远不要通过杀死进程或CTRL+C命令来停止服务器。 始终使用脚本来停止服务器。

学习愉快!

参考:

源码下载