VIP20
本课程属于：083-风控规则引擎PSI漂移告警 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

风控PSI漂移告警Kafka集成实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
PSI概念与风控意义
PSI（群体稳定性指标）的定义 · 计算公式 · 在风控模型监控中的核心价值
PSI概念
02
PSI漂移阈值设定
PSI阈值的行业标准（0.1/0.2… · 不同业务场景下的阈值调整策略
PSI漂移阈值设定
03
Kafka基础架构
Kafka核心组件（Producer · Broker · Consumer
Kafka基础架构
04
Kafka集群部署
单机与集群模式搭建 · ZooKeeper/KRaft模式对… · 关键配置参数（acks
Kafka集群部署
05
风控数据流设计
实时风控数据管道架构 · 特征数据入Kafka的Topic设计…
风控数据流设计实时风控数据管道…
06
PSI计算引擎选型
Flink vs Spark Str…
PSI计算引擎选型
07
Kafka Streams入门
KStream与KTable概念 · 状态存储 · 窗口操作基础
KafkaStreams
08
实时PSI计算实现
使用Kafka Streams实现滑…
PSI实时
09
特征分布统计
实时统计每个特征的分箱频数 · 概率分布 · 输出到中间Topic
特征分布统计实时统计每个特征…
10
参考分布存储
将训练集/基准期的特征分布存入Kaf…
参考分布存储Kaf
11
PSI告警触发机制
当实时PSI超过阈值时 · 生成告警事件并发送到告警Topic
PSI告警触发机制
12
告警消息格式设计
JSON Schema设计（包含特征… · PSI值 · 时间窗口
告警消息格式设计JSON
13
Kafka Connect集成
使用Kafka Connect将告警…
KafkaConnect
14
告警降噪策略
连续N次超阈值才告警 · 排除周期性波动 · 基于历史基线动态调整阈值
告警降噪策略连续N次超阈值才…
15
多特征并行监控
如何设计Topic分区策略 · 实现数百个特征PSI的并行计算与隔离
多特征并行监控Topic
16
延迟与吞吐优化
调整Kafka参数（linger.m… · batch.size） · 优化序列化（Avro/Protobu…
延迟吞吐优化
17
数据质量监控
对入Kafka的特征数据进行空值率 · 异常值检测 · 防止脏数据导致PSI误报
数据质量监控Kafka
18
告警通知渠道
集成钉钉/企微/邮件Webhook · 将告警消息推送至运维群
告警通知渠道Webhook
19
告警事件回溯
将告警事件持久化到HDFS/Clic… · 支持事后分析与报表
告警事件回溯HDFS/Clic
20
PSI漂移根因分析
结合SHAP值或特征重要性 · 定位导致PSI漂移的主要特征分箱
PSI漂移根因分析
21
A/B测试与PSI监控
在模型A/B测试场景中 · 使用PSI监控实验组与对照组分布差异
A/BPSI
22
多模型版本管理
Kafka消息中携带模型版本号 · 支持不同版本PSI的独立监控与对比
多模型版本管理Kafka
23
可视化看板搭建
使用Grafana展示实时PSI曲线 · 告警事件时间线 · 特征分布变化
可视化看板搭建Grafana
24
Kafka安全与权限
SASL/SSL认证 · ACL权限控制 · 保障风控数据流安全
Kafka安全
25
容错与Exactly-Once语义
Kafka Streams的EOS配… · 幂等性Producer · 事务性写入
Exactly-Once容错
26
压力测试方案
使用Kafka自带的性能测试工具（k…
压力测试方案Kafka
27
生产环境排障
常见问题（Rebalance频繁 · 消息积压 · OOM）的诊断与解决
生产环境排障Rebalance
28
与现有风控平台集成
将PSI告警系统嵌入到已有风控决策引…
现有风控平台集成PSI
29
案例实战
信贷风控场景——用户收入特征PSI漂…
案例实战PSI
30
课程总结与最佳实践
架构设计要点 · 监控指标 · 团队协作规范
课程总结最佳实践