第四章 Kafka与Streaming集成

Kafka之四：Kafka与Streaming集成

---

文章结构概述

• Kafka之四：Kafka与Streaming集成
  • • 1. 调整IEDA中的maven配置设置
    • 2. 示例代码一
    • 3. 示例代码二：用于计算出现频率
    • 4. 在提交任务过程中可能出现的问题

---

Kafka之一：Kafka简述
Kafka之二：Kafka集群的安装
Kafka之三：Kafka集群工作流程

---

• spark官网
• 在spark Streaming框架中，Kafka被用作数据输入源，当实现Kafka与Streaming的整合时，其承担着消费者的功能。（建议熟悉Kafka的相关命令操作）

---

1. 修改IEDA的maven配置

依据官方网站提供的配置信息对maven项目中的pom.xml文件进行相应调整

![在这里插入图片描述](https://cdl.itad