VIP20

本课程属于：090-反欺诈图谱Kafka回放链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

Kafka回放链路反欺诈图数据血缘课程

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

反欺诈场景下的数据血缘需求 · Kafka回放链路的核心挑战 · 图数据血缘的价值

课程导论反欺诈场景下的数…

Kafka基础回顾

Topic与Partition机制 · Producer与Consumer模… · 消息的存储与偏移量管理

Kafka基础回顾

回放链路定义

什么是Kafka消息回放 · 回放触发场景（数据修复 · 审计

回放链路定义Kafka

反欺诈数据模型

欺诈事件的数据结构 · 实体（用户 · 设备

反欺诈数据模型欺诈事件的数据结…

图数据血缘概念

血缘的起源（数据仓库） · 图数据血缘 vs 传统血缘 · 在反欺诈中的特殊意义

图数据血缘概念血缘的起源

图数据库选型

Neo4j · JanusGraph · Dgraph对比

图数据库选型Neo4j

Kafka Connect与图数据导入

Source Connector配置 · Sink Connector写入图数… · Schema Registry集成

回放链路数据采集

使用Kafka Consumer A… · 消息去重与顺序保证 · 水位线（Watermark）管理

回放链路数据采集Kafka

实体节点构建

从Kafka消息中提取用户 · 设备 · IP

实体节点构建Kafka

关系边构建

从消息中提取转账 · 登录 · 注册

关系边构建从消息

时间窗口与滑动窗口

反欺诈中时间窗口的重要性 · 滑动窗口在回放链路中的实现 · 窗口内图模式聚合

时间窗口滑动窗口

图模式匹配基础

子图同构 · 路径查询 · 社区发现

图模式匹配基础子图同构

回放链路中的异常检测

基于图度的异常（星型结构） · 基于路径的异常（长链转账） · 基于时间序列的异常

回放链路异常检测

实时回放 vs 离线回放

实时流处理（Flink+Kafka）…

图数据血缘存储策略

节点与边的TTL · 历史版本管理 · 冷热数据分离

图数据血缘存储策…TTL

反欺诈规则引擎与图血缘联动

规则引擎（Drools）触发图查询 · 规则热更新 · 规则冲突检测

反欺诈规则引擎图血缘联动

图查询语言实战

Cypher（Neo4j）与Grem…

图查询语言实战Cypher

回放链路性能优化

Kafka消费并行度调优 · 图数据库批量写入 · 缓存策略（Redis + 图缓存）

回放链路性能优化Kafka

数据一致性保障

Exactly-Once语义在回放链… · 分布式事务（Kafka事务 + 图数…

数据一致性保障Exactly-Once

图数据血缘可视化

使用D3.js或Gephi展示回放链… · 交互式探索与下钻

图数据血缘可视化D3.js

案例实战一

信用卡盗刷回放分析——从Kafka日… · 识别盗刷团伙

案例实战一Kafka

案例实战二

账号批量注册检测——回放注册事件流 · 构建设备-账号二部图 · 发现机器注册

案例实战二账号批量注册检测

案例实战三

洗钱链路追踪——回放转账消息 · 构建资金流转图 · 识别多层洗钱路径

案例实战三洗钱链路追踪

案例实战四

撞库攻击检测——回放登录失败事件 · 构建IP-账号图 · 发现暴力破解模式

案例实战四撞库攻击检测

图数据血缘的元数据管理

血缘元数据模型 · 数据字典 · 字段级血缘追踪

图数据血缘的元数…血缘元数据模型

回放链路监控与告警

Kafka Lag监控 · 图数据库写入延迟 · 异常图模式自动告警

回放链路监控告警

安全与合规

图数据脱敏 · 访问控制（RBAC） · 审计日志

图数据血缘的测试策略

单元测试（图构建逻辑） · 集成测试（Kafka+图DB） · 混沌工程（回放链路容错）

图数据血缘的测试…单元测试

图神经网络（GNN）在反欺诈中的应用 · 实时图计算引擎（如GraphScop… · Kafka与图数据库的云原生演进

未来趋势GNN

课程总结与项目实战

综合项目——构建一个端到端的Kafk… · 涵盖采集 · 构建

课程总结项目实战