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

规则引擎PSI漂移告警Kafka实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
PSI漂移概念 · 规则引擎与Kafka结合的价值 · 课程目标与前置知识
课程导论PSI
02
PSI漂移基础
PSI（群体稳定性指标）定义 · 计算公式 · 漂移阈值与业务含义
PSI漂移基础
03
规则引擎概述
规则引擎核心概念（规则 · 事实 · 动作）
规则引擎概述规则引擎核心概念
04
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
05
Kafka消息模型
点对点模型与发布订阅模型 · 消息确认机制（ACK）
Kafka消息模型
06
Kafka集群搭建
单机与集群部署 · ZooKeeper/KRaft模式 · 常用配置项
Kafka集群搭建
07
Kafka生产者API
同步发送 · 异步发送 · 回调
KafkaAPI
08
Kafka消费者API
订阅模式 · 手动提交偏移量 · 消费者组与再均衡
KafkaAPI
09
Kafka Streams入门
流处理概念 · KStream与KTable · 状态存储
KafkaStreams
10
规则引擎与Kafka集成架构
数据流拓扑 · 规则触发流程 · 架构图设计
Kafka规则引擎
11
PSI漂移计算模块设计
滑动窗口 · 分桶策略 · 频率统计实现
PSI漂移计算模块设计
12
规则定义与DSL设计
规则语言设计 · 条件表达式 · 动作定义
DSL规则定义
13
规则引擎核心实现
规则编译 · 规则匹配 · 冲突解决策略
规则引擎核心实现规则编译
14
Kafka消息序列化与反序列化
Avro/Protobuf/JSON…
Kafka消息序列化
15
实时PSI漂移计算
基于Kafka Streams的滑动…
PSI实时
16
告警规则配置
阈值设定 · 告警级别 · 告警频率控制
告警规则配置阈值设定
17
告警消息生成与发送
Kafka告警Topic设计 · 告警消息格式
告警消息生成发送
18
告警消费与通知
消费者解析告警 · 邮件/短信/Webhook通知集成
告警消费通知
19
规则引擎状态管理
内存状态与持久化状态 · 状态恢复与容错
规则引擎状态管理内存状态
20
Kafka Exactly-Once语义
事务性生产者 · 幂等性 · 流处理中的EOS
KafkaExactly-Once
21
性能优化
Kafka参数调优 · 规则引擎并行度 · 内存与CPU优化
性能优化Kafka
22
监控与告警
Kafka监控指标（Lag · 吞吐量） · 规则引擎健康检查
监控告警
23
单元测试与集成测试
规则引擎测试 · Kafka流处理测试（Topolog…
单元测试集成测试
24
部署与运维
Docker容器化部署 · Kubernetes编排 · 日志与链路追踪
部署运维
25
案例实战一
电商场景PSI漂移检测（用户画像分布…
案例实战一PSI
26
案例实战二
金融风控场景PSI漂移检测（交易特征…
案例实战二PSI
27
案例实战三
IoT设备数据PSI漂移检测（传感器…
案例实战三IoT
28
常见问题与排错
数据倾斜 · 规则不触发 · Kafka消费延迟
常见问题排错
29
扩展与进阶
多规则引擎协同 · 机器学习辅助漂移检测 · 联邦PSI
扩展进阶
30
课程总结与展望
知识体系回顾 · 最佳实践总结 · 未来演进方向
课程总结知识体系回顾