安监网站如何做紧急预案备案今天新闻最新消息

1. 背景说明

在搭建基于Kafka的数据流通系统（例如流式推荐、实时日志采集）时，常见的操作是：

• 生产者 Producer 向 Kafka Topic 写入消息
• 消费者 Consumer 从 Kafka Topic 读取消息

本文以Windows本地环境 + Kafka 2.8.1版本为例，手把手演示生产消费流程。

---

2. 准备条件

• Kafka 已经正确安装并启动
• Topic（如：recommender）已存在，或可通过命令动态创建
• 本机端口 9092 正常监听（Kafka默认端口）

---

3. Kafka生产者发送消息（Producer）

3.1 打开CMD，进入Kafka目录

cd D:\kafka_2.12-2.8.1

3.2 启动Kafka生产者

bin\windows