VIP20
本课程属于：090-反欺诈图谱Kafka回放链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka回放链路反欺诈图模型训练教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Kafka回放链路反欺诈的背景 · 图模型在反欺诈中的价值 · 课程目标与学习路径
课程导论Kafka
02
Kafka核心概念回顾
Topic · Partition · Producer
Kafka核心概念回顾
03
Kafka回放机制详解
回放场景（数据修复 · 模型重训 · 审计）
Kafka回放机制详解
04
反欺诈基础概念
欺诈模式分类（账户盗用 · 薅羊毛 · 洗钱）
反欺诈基础概念欺诈模式分类
05
图模型基础
图论入门（节点 · 边 · 度
图模型基础图论入门
06
反欺诈图模型设计
用户-设备-IP-交易四层异构图 · 边类型定义（登录 · 转账
反欺诈图模型设计IP
07
Kafka回放链路数据流架构
数据源（埋点 · 日志）→ Kafka → Flink…
Kafka回放链路数据流架…
08
数据采集与预处理
埋点规范 · 日志清洗 · 字段映射（user_id
数据采集预处理
09
Kafka消息序列化与反序列化
Avro · Protobuf · JSON Schema的选择
Kafka消息序列化
10
Kafka Connect与数据管道
Source Connector（M… · File） · Sink Connector（HDF…
KafkaConnect
11
实时流处理引擎选型
Flink vs Spark Str… · 延迟 · 吞吐
实时流处理引擎选…Flink
12
Flink消费Kafka实现回放
FlinkKafkaConsumer… · Checkpoint与Exactly… · 动态分区发现
FlinkKafka
13
图构建引擎开发
从Kafka消息流中提取节点与边 · 去重与合并逻辑 · 批量写入图数据库（Gremlin/C…
图构建引擎开发Kafka
14
图特征工程
节点特征（历史交易次数 · 设备指纹） · 边特征（交易金额
图特征工程节点特征
15
图模型训练框架
PyTorch Geometric（… · 图神经网络（GNN）基础 · 消息传递机制
图模型训练框架PyTorch
16
反欺诈图模型选型
GCN · GAT · GraphSAGE
反欺诈图模型选型GCN
17
模型训练数据准备
从图数据库导出子图 · 正负样本构建（已知欺诈节点 vs 随… · 训练/验证/测试集划分
模型训练数据准备从图数据库导出子…
18
Kafka回放链路数据一致性
幂等性处理 · 去重策略（基于Offset+Part… · 回放时的Exactly-Once语义…
Kafka回放链路数据一致…
19
模型训练与调优
损失函数（交叉熵 · Focal Loss） · 优化器（Adam）
模型训练调优
20
模型评估指标
准确率 · 召回率 · F1-Score
模型评估指标准确率
21
实时推理管道
Kafka → Flink → 图模… · 端到端延迟优化
实时推理管道Kafka
22
模型部署与版本管理
模型序列化（TorchScript/… · 模型注册中心（MLflow） · A/B测试与灰度发布
模型部署版本管理
23
反欺诈规则引擎与图模型融合
规则引擎（Drools）兜底 · 图模型评分加权 · 动态阈值调整
反欺诈规则引擎图模型融合
24
大规模图存储与查询
分布式图数据库（JanusGraph… · 图分区策略 · 索引优化（顶点中心索引）
大规模图存储查询
25
Kafka回放链路监控与告警
Consumer Lag监控 · 回放进度追踪 · 数据质量告警（字段缺失
Kafka回放链路监控
26
案例实战一
信用卡盗刷检测——基于Kafka回放… · 构建用户-商户-设备异构图 · 训练GAT模型
案例实战一Kafka
27
案例实战二
薅羊毛团伙识别——基于Kafka回放… · 构建用户-IP-设备图 · 训练GraphSAGE模型
案例实战二Kafka
28
案例实战三
洗钱网络挖掘——基于Kafka回放转… · 构建账户-账户-金额图 · 训练RGCN模型
案例实战三Kafka
29
性能优化与成本控制
Kafka分区数调优 · 图模型推理批处理 · 图数据库写入批量优化
性能优化成本控制
30
课程总结与进阶方向
图模型可解释性（GNNExplain… · 联邦图学习 · 时序图神经网络（TGNN）
课程总结进阶方向