VIP20
本课程属于：091-Confluent Kafka实时数据平台工程 后端、数据与云原生工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Confluent Kafka机器学习数据平台集成

共计 30 章节
可可资料掘金营 · 点击在线试看
01
课程导入与全景认知
目标=Confluent Kafka… · 核心价值 · 典型架构与学习路径
课程导入全景认知
02
Confluent Kafka核心概念精讲
目标=Topic · Partition · Offset
ConfluentKafka
03
Schema Registry与数据契约
目标=Avro · Protobuf · JSON Schema的注册
SchemaRegistry
04
Kafka Connect数据接入实战
目标=从数据库 · 对象存储 · 日志系统向Kafka主题实时同步机器…
KafkaConnect
05
Kafka Connect数据导出实战
目标=将Kafka中的特征 · 预测结果与监控指标写入数据湖 · 特征库或在线存储
KafkaConnect
06
ksqlDB实时特征工程入门
目标=使用SQL在流上完成过滤 · 聚合 · 窗口计算与简单特征生成
ksqlDB实时特征工程入门
07
ksqlDB高级流处理
目标=流表连接 · 时间窗口 · 延迟数据处理与实时特征回填策略
ksqlDB高级流处理
08
Kafka Streams构建实时特征管道
目标=拓扑设计 · 状态存储 · Exactly-Once语义与容错处…
KafkaStreams
09
Confluent Cloud环境搭建
目标=集群创建 · 网络配置 · 访问控制
ConfluentCloud
10
生产者与消费者客户端开发
目标=Python/Java客户端配… · 序列化 · 批量发送
生产者消费者客户端开发
11
实时数据质量监控
目标=在Kafka管道中嵌入数据校验 · 异常检测 · 死信队列与告警机制
实时数据质量监控Kafka
12
特征存储与Kafka集成
目标=将实时特征写入Feast · Tecton或自研特征库 · 并保证线上线下一致性
Kafka特征存储
13
模型训练数据准备
目标=从Kafka主题消费历史数据 · 构建训练集 · 处理时间旅行与数据版本管理
模型训练数据准备Kafka
14
实时模型推理管道
目标=将Kafka作为输入输出总线 · 集成模型服务 · 批推理与流式推理
实时模型推理管道Kafka
15
模型监控与反馈闭环
目标=通过Kafka收集预测结果 · 真实标签与漂移指标 · 触发再训练流程
模型监控反馈闭环
16
Flink与Kafka集成
目标=使用Flink SQL/Dat…
FlinkKafka
17
Spark Structured Streaming与Kafka
目标=微批处理 · 连续处理模式与离线/实时特征统一计算
SparkStructured
18
Kafka在MLOps流水线中的角色
目标=连接数据版本 · 实验跟踪 · 模型注册与部署编排
KafkaMLOps
19
安全与治理
目标=SSL/SASL认证 · RBAC授权 · 审计日志
安全治理
20
性能调优与容量规划
目标=分区策略 · 副本因子 · 压缩
性能调优容量规划
21
容灾与多集群架构
目标=MirrorMaker 2 · Cluster Linking · 跨地域复制与故障转移策略
容灾多集群架构
22
案例实战一
目标=电商实时推荐特征管道——从点击…
案例实战一目标=电商实时推…
23
案例实战二
目标=金融风控实时特征与模型推理——… · 高可靠与可解释性
案例实战二目标=金融风控实…
24
案例实战三
目标=物联网预测性维护——设备遥测数… · 异常检测与模型更新
案例实战三目标=物联网预测…
25
案例实战四
目标=自然语言处理实时管道——文本流… · 嵌入生成与在线分类
案例实战四目标=自然语言处…
26
Kafka与向量数据库集成
目标=实时嵌入写入 · 相似性搜索与RAG应用数据流
Kafka向量数据库集成
27
成本优化与资源治理
目标=分层存储 · 智能压缩 · 弹性伸缩与多云部署成本控制
成本优化资源治理
28
测试与模拟
目标=单元测试 · 集成测试 · 压力测试与混沌工程在Kafka ML…
测试模拟
29
可观测性体系
目标=指标 · 日志 · 追踪在Confluent Kafka…
可观测性体系目标=指标
30
综合项目
目标=设计并实现一个端到端的Conf… · 涵盖数据接入 · 特征工程
综合项目Conf