VIP20
本课程属于：076-量化因子研究阈值漂移巡查 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

基于Kafka的因子漂移实时巡查实践课

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
因子漂移的定义 · 实时巡查的业务价值 · 课程目标与前置知识
课程导论因子漂移的定义
02
Kafka核心概念回顾
Topic · Partition · Producer
Kafka核心概念回顾
03
Kafka集群环境搭建
单机与集群模式部署 · ZooKeeper/KRaft配置 · 常用命令行工具
Kafka集群环境搭建
04
Kafka生产者深入
发送模式（同步/异步） · 分区策略 · 消息序列化与自定义Partition…
Kafka生产者深入
05
Kafka消费者深入
消费组与再均衡 · 位移提交（自动/手动） · 幂等性与事务
Kafka消费者深入
06
Kafka Streams入门
流处理拓扑 · KTable与KStream · 状态存储与窗口操作
KafkaStreams
07
因子漂移检测原理
统计漂移（PSI/KL散度） · 模型漂移（数据漂移/概念漂移） · 实时检测挑战
因子漂移检测原理PSI/KL
08
实时数据管道设计
Lambda架构与Kappa架构对比 · 基于Kafka的流式数据湖方案
实时数据管道设计Lambda
09
因子数据采集与标准化
多源异构因子接入 · Avro/Protobuf序列化 · Schema Registry集成
因子数据采集标准化
10
Kafka Connect实战
Source Connector与S… · JDBC/MongoDB连接器案例
KafkaConnect
11
实时漂移计算引擎选型
Flink vs Kafka Str…
实时漂移计算引擎…Flink
12
Flink集成Kafka基础
Flink Kafka Consum… · Checkpoint与Exactly…
FlinkKafka
13
基于Flink的滑动窗口漂移计算
窗口定义 · 聚合函数 · 水位线（Watermark）处理
Flink基于
14
PSI（群体稳定性指标）实时计算
PSI公式推导 · 分箱策略 · Flink实现代码
PSI群体稳定性指标
15
KL散度与JS散度实时计算
概率分布对齐 · 实时直方图更新 · 阈值告警
KLJS
16
特征重要性漂移监控
基于树模型的特征重要性变化检测 · 实时特征排序流
特征重要性漂移监…基于树模型的特征…
17
模型预测分布漂移监控
实时收集模型打分结果 · KS检验与分布对比
模型预测分布漂移…实时收集模型打分…
18
告警规则引擎设计
基于Drools/Flink CEP… · 多级告警策略
告警规则引擎设计Drools/Flink
19
实时巡查看板开发
WebSocket推送 · ECharts实时图表 · Grafana与Kafka数据源
实时巡查看板开发WebSocket
20
Kafka监控与运维
JMX指标 · Burrow消费者延迟监控 · Cruise Control集群重平…
Kafka监控
21
数据质量保障
Kafka消息完整性校验 · 死信队列（DLQ）设计 · 重试机制
数据质量保障Kafka
22
多环境部署策略
开发/测试/生产环境隔离 · 配置中心（Apollo/Nacos）…
多环境部署策略开发
23
性能调优实战
Kafka参数调优（batch.si… · Flink并行度优化
性能调优实战Kafka
24
容错与高可用设计
Kafka副本机制 · Flink Savepoint与状态… · 异地多活方案
容错高可用设计
25
安全实践
Kafka SSL加密 · SASL认证 · RBAC权限控制
安全实践Kafka
26
案例实战一
金融风控因子漂移实时巡查——信贷评分…
案例实战一金融风控因子漂移…
27
案例实战二
推荐系统特征漂移实时巡查——CTR模…
案例实战二CTR
28
案例实战三
IoT传感器数据漂移实时巡查——设备…
案例实战三IoT
29
自动化测试与混沌工程
Kafka消息模拟 · 漂移注入测试 · 故障演练
自动化测试混沌工程
30
课程总结与展望
最佳实践总结 · 业界前沿（e.g. 实时ML · Feature Store）
课程总结最佳实践总结