📅 最后修改于: 2023-12-03 15:39:17.691000 🧑 作者: Mango
Kafka 是一个高性能、分布式、可伸缩的消息队列系统，常用于大规模数据处理和实时数据流处理。本文将介绍如何将数据放入 Windows 中的 Kafka 生产者。
在 Apache Kafka 的官网上下载 Kafka 的二进制文件，并解压到任意位置。
Kafka 使用 Zookeeper 作为协调者来管理集群中的 Kafka brokers。首先需要启动 Zookeeper 服务。
在 Kafka 解压后的目录下，打开命令行窗口，执行以下命令：
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
在启动 Kafka broker 之前，需要先编辑 Kafka 中的配置文件。在 Kafka 解压后的目录下，找到 config\server.properties 文件，并修改以下参数：
listeners=PLAINTEXT://localhost:9092
将其中的 localhost 改为自己的计算机名，这样客户端才能访问到 Kafka。
启动 Kafka broker 的命令如下：
.\bin\windows\kafka-server-start.bat .\config\server.properties
在 Kafka 中，数据是通过 topic 进行发布和订阅的。可以使用 kafka-topics.bat 命令行工具来创建一个 topic。
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my-topic
其中，--replication-factor 指定副本数量，--partitions 指定分区数量。
在 Windows 中使用 Kafka 生产数据，可以使用 kafka-console-producer.bat 命令行工具。
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic my-topic
这会启动一个新的命令行窗口，并进入到生产者模式。在这里，可以输入任意文本，并按 Enter 键发送到 Kafka。
使用 kafka-console-consumer.bat 命令行工具可以查看 Kafka topic 中的消息。
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic my-topic --from-beginning
这会启动一个新的命令行窗口，并显示 Kafka topic 中收到的消息。
通过以上步骤，我们可以将数据放入 Windows 中的 Kafka 生产者，并将数据保存到 Kafka topic 中。在实际应用中，Kafka 还可以用于数据流处理、数据分析等场景。