VIP20
本课程属于：003-实时流处理 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka Streams实时业务应用开发

📚 共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Kafka Streams 初探
流处理本质 · Kafka Streams 定位与优势 · 对比 Spark/Flink
概念对比
02
环境准备
Kafka 集群搭建 · Maven/Gradle 依赖 · Hello World
实战环境
03
核心概念
Topology · Stream · Processor · State Store
抽象原理
04
Streams DSL 基础
KStream · KTable · GlobalKTable 区别与联系
DSL核心
05
数据源与数据汇
Consumed · Produced · Serdes 配置与自定义
序列化配置
06
基本算子 (上)
map · flatMap · mapValues · filter · filterNot
算子转换
07
基本算子 (下)
selectKey · branch · split · merge 分流与合并
路由分支
08
聚合操作
groupBy · count · reduce · aggregate 与状态存储
聚合状态
09
窗口操作
Tumbling · Hopping · Sliding · Session Window
时间窗口
10
Join 操作
KStream-KStream · KStream-KTable · KTable-KTable
关联流表
11
状态存储
KeyValueStore · WindowStore · 持久化与容错
存储容错
12
Processor API 入门
自定义 Processor · Transformer · 适用场景
底层API
13
拓扑构建与优化
复杂拓扑构建 · 命名与调试技巧
拓扑优化
14
配置详解
StreamsConfig 核心参数 · bootstrap.servers · commit.interval.ms
配置调优
15
线程模型
线程模型 · 任务分配 · 并行度控制
并发架构
16
容错机制
Exactly-Once · 事务与幂等性 · 故障恢复
一致性可靠性
17
监控与运维
JMX 指标 · 日志配置 · Metrics 解读
监控运维
18
交互式查询
State Store 对外查询 · REST API 集成
查询API
19
测试策略
TopologyTestDriver · 单元测试 · 集成测试
测试质量
20
部署与调优
Docker/K8s 部署 · 资源分配 · 性能调优
部署性能
21
实战：用户行为日志清洗
实时过滤与字段规整 · 脏数据剔除
实战清洗
22
实战：订单金额统计与预警
实时聚合 · 阈值告警 · 窗口统计
实战预警
23
实战：推荐系统用户画像
实时标签更新 · 行为聚合 · 画像存储
实战推荐
24
实战：物联网设备异常检测
数据聚合 · 滑动窗口 · 异常判别
实战IoT
25
实战：CDC 与 ETL 管道
实时数据同步 · 转换与分发
实战CDC
26
Schema Registry 集成
Avro/Protobuf 序列化 · 兼容性管理
Schema序列化
27
Kafka Streams 与 KSQL 对比
API vs SQL · 选型建议
对比选型
28
常见坑与避指南
Rebalance · 状态膨胀 · 序列化异常
经验排错
29
版本演进
2.x → 3.x 重要变化与新特性
版本迁移
30
总结与展望
未来趋势 · 学习路径 · 社区资源
总结路线