【云原生】Kafka在window里运行入门篇

Apache Kafka – 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命令将其解压缩。

  > 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 配置文件路径。

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

3.2 启动 Kafka

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

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

3.3 关闭 Kafka

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

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

3.4 关闭 Zookeeper

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

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

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

4. 验证 Kafka 安装

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

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

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

• 现在列出所有主题以验证创建的主题是否存在于此列表中。 在这一步，我们只有一个主题。

  > bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092
  
  //Output:
  
  test
  
  

• 现在列出所有主题，以验证创建的主题是否存在于此列表中。 在这一步，我们只有一个主题。

  > bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092
  
  //Output:
  
  test
  
  

• 产生一些消息并提交给test主题。 我添加了两个消息，即“Hello”和“Kafka”。

  > bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test
  
  

• 使用消息并提交到test主题。

  > bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
  
  //Output:
  
  Hello
  Kafka
  
  

验证 Kafka 安装

5. 总结

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

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

参考：

源码下载