Apache Kafka系列 – Kafka Streams数据处理

使用Java 8构建和部署Kafka Streams应用

学习内容：

* 使用Java 8编写四个Kafka Streams应用程序
* 配置Kafka Streams以使用“精确一次语义”（Exactly Once Semantics）
* 扩展Kafka Streams应用程序
* 使用Kafka Streams的高级DSL进行编程
* 构建并打包应用程序
* 为Kafka Streams拓扑编写测试
* 掌握更多高级操作与实践案例

课程内容主题：

* Kafka Streams初体验：运行第一个WordCount应用
* 端到端Kafka Streams应用开发：从代码编写到打包部署
* KStream和KTable的无状态操作（Map、Filter、FlatMap等）
* 实践练习：FavouriteColour应用开发（含Scala示例）
* KStream和KTable的有状态操作（聚合、Join、Reduce等）
* 精确一次语义（Exactly Once）的理论与实践（BankBalance案例）
* Kafka Streams应用的测试方法与工具

课程要求：

* 熟悉Apache Kafka的基础知识
* 配备4GB RAM的计算机（支持Windows/Linux/Mac OS X）
* 掌握Java 8编程语言

课程详细描述：

* **课程亮点**：

– 通过实践案例深入学习Kafka Streams API，涵盖无状态与有状态操作。

– 掌握“精确一次语义”（Exactly Once）的实现原理与应用场景。

– 学习如何构建、打包并部署Kafka Streams应用，无需依赖集群环境。

– 提供完整的项目开发流程，包括调试、测试与扩展方法。
* **课程结构**：

– 从基础到高级，分章节讲解Kafka Streams的核心概念与操作。

– 每个章节包含理论讲解与实践练习，帮助学员巩固知识。

– 包含多个实战案例（如WordCount、BankBalance、FavouriteColour），覆盖常见业务场景。
* **讲师背景**：

– Stephane Maarek（AWS认证专家、Apache Kafka社区贡献者），拥有丰富的教学经验与企业级项目实战经验。

– Conduktor团队联合创始人，专注于Kafka生态系统的开发与推广。
* **附加资源**：

– 提供课程代码、测试案例与扩展练习，支持Java 8与Scala语言。

– 包含Kafka Streams的高级主题（如Join操作、状态管理、Exactly Once语义）。
* **适用人群**：

– 希望掌握Kafka Streams数据处理能力的开发人员与DevOps工程师。

– 需要理解Kafka在企业级数据管道中的架构师与技术决策者。

– 已具备Apache Kafka基础知识，希望深入学习流处理技术的Java/Scala开发者。

B站免费课程

更多 商业分析与智能 教程