VIP20
本课程属于：016-支付风控策略分群评分沙盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka实时流处理在风控评分中的应用

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风控评分概述
金融风控的定义 · 评分卡模型简介 · 实时风控与传统风控的区别
风控评分概述金融风控的定义
02
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
03
Kafka集群搭建
单机与集群部署 · 关键配置参数（acks · replication-factor…
Kafka集群搭建
04
Kafka消息模型
点对点模型与发布订阅模型 · 消息的持久化与顺序保证
Kafka消息模型
05
Kafka生产者API
同步发送 · 异步发送 · 回调函数
KafkaAPI
06
Kafka消费者API
消费者组概念 · offset提交机制（自动/手动） · 再均衡监听器
KafkaAPI
07
Kafka Streams入门
Streams DSL · Processor API · 状态存储与窗口操作
KafkaStreams
08
Kafka Connect与数据集成
Source Connector · Sink Connector · JDBC Connector实战
KafkaConnect
09
风控数据源接入
用户行为日志 · 交易流水 · 设备指纹
风控数据源接入用户行为日志
10
实时特征工程
滑动窗口统计（交易频次 · 金额聚合） · 时间衰减特征
实时特征工程滑动窗口统计
11
风控规则引擎
基于Kafka Streams的规则… · 黑白名单规则 · 频控规则）
风控规则引擎Kafka
12
评分卡模型部署
将训练好的逻辑回归/XGBoost模… · 集成到Kafka Streams
评分卡模型部署XGBoost
13
实时模型推理
使用Kafka Streams调用模…
实时模型推理Kafka
14
特征存储与回刷
使用Redis或HBase作为特征存… · Kafka Streams实现特征实…
特征存储回刷
15
风控事件序列化
Avro与Protobuf在风控消息… · 兼容性策略
风控事件序列化Avro
16
Kafka事务与幂等性
Exactly-Once语义在风控扣…
Kafka事务
17
风控结果回写
将评分结果 · 拒绝原因 · 处置动作写入Kafka结果Topic
风控结果回写将评分结果
18
实时监控与告警
Kafka Lag监控 · 消费者健康检查 · 风控命中率Dashboard（Gra…
实时监控告警
19
Kafka与Flink集成
Flink作为更强大的流处理引擎 · 与Kafka结合实现复杂风控逻辑
KafkaFlink
20
多级风控架构
第一级规则过滤 · 第二级模型评分 · 第三级人工审核的Kafka拓扑设计
多级风控架构第一级规则过滤
21
风控数据血缘追踪
使用Kafka消息头（Header）… · 实现全链路数据溯源
风控数据血缘追踪Kafka
22
压力测试与性能调优
Kafka生产者和消费者参数调优 · 批量大小 · 压缩算法（gzip/lz4/zstd…
压力测试性能调优
23
Kafka安全机制
SSL/TLS加密 · SASL认证（PLAIN/SCRAM… · ACL权限控制
Kafka安全机制
24
跨数据中心复制
MirrorMaker 2.0实现风…
跨数据心复制
25
实时特征重要性分析
利用Kafka Streams计算特… · PSI（群体稳定性指标）监控
实时特征重要性分…Kafka
26
风控实验平台
基于Kafka的A/B测试流量路由 · 不同模型版本并行评分对比
风控实验平台Kafka
27
Kafka与图计算
结合Neo4j或JanusGraph · 在流中实时查询关联图谱（团伙欺诈检测…
Kafka图计算
28
风控事件时间语义
Event Time vs Proc… · 水位线（Watermark）在乱序事…
风控事件时间语义Event
29
Kafka日志压缩与清理
Log Compaction在风控黑…
Kafka日志压缩
30
综合实战案例
从零搭建一个实时交易风控评分系统 · 涵盖数据接入 · 特征计算
综合实战案例从零搭建一个实时…