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

金融图谱回放验证与Kafka实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
金融图谱回放验证的背景与意义 · Kafka在金融数据流中的核心作用 · 课程整体架构与学习目标
课程导论金融图谱回放验证…
02
金融图谱基础
实体-关系模型 · 金融知识图谱的典型应用场景（风控 · 反欺诈
金融图谱基础实体
03
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
04
Kafka集群部署
单机与集群模式搭建 · 关键配置参数（副本因子 · ISR
Kafka集群部署
05
Kafka生产者实战
发送消息的三种方式（同步 · 异步 · 回调）
Kafka生产者实战
06
Kafka消费者实战
消费组与再平衡 · 位移提交机制（自动/手动） · 幂等性与事务保证
Kafka消费者实战
07
Kafka高级特性
时间戳提取器 · 拦截器 · 流式处理（Kafka Streams…
Kafka高级特性
08
金融图谱数据建模
节点与边的Schema设计 · 属性定义 · 关系方向与权重
金融图谱数据建模Schema
09
图谱数据生成与序列化
使用Avro/Protobuf定义图… · Schema Registry集成
图谱数据生成序列化
10
Kafka Connect实战
使用Source Connector… · Sink Connector写入图数…
KafkaConnect
11
图谱事件流定义
节点新增/更新/删除事件 · 关系新增/更新/删除事件 · 事件版本控制
图谱事件流定义节点新增
12
回放验证概念
什么是回放验证 · 与实时处理的区别 · 在金融合规与审计中的价值
回放验证概念什么是回放验证
13
回放验证架构设计
事件源（Event Sourcing… · 状态机与快照 · 回放时间窗口
回放验证架构设计Event
14
Kafka消息回溯机制
基于Offset的回放 · 基于时间戳的回放 · 重置消费组Offset
Kafka消息回溯机制
15
图谱状态快照管理
全量快照与增量快照 · 快照存储（HDFS/S3） · 快照恢复流程
图谱状态快照管理全量快照
16
回放验证引擎实现
Python/Java消费者逻辑 · 事件重放顺序保证 · 幂等性处理
回放验证引擎实现Python/Java
17
金融图谱回放场景1
交易链路回放——从订单生成到结算的全…
金融图谱回放场景…交易链路回放
18
金融图谱回放场景2
反欺诈规则回放——历史欺诈事件的特征…
金融图谱回放场景…反欺诈规则回放
19
金融图谱回放场景3
风控模型回放——基于历史图谱特征的模…
金融图谱回放场景…风控模型回放
20
回放结果校验
预期状态与实际状态对比 · 差异报告生成 · 自动化断言框架
回放结果校验预期状态
21
Kafka监控与运维
JMX指标 · Lag监控 · Cruise Control集群重平…
Kafka监控
22
数据一致性保障
Exactly-Once语义在回放中… · Kafka事务与幂等生产者
数据一致性保障Exactly-Once
23
大规模图谱回放性能优化
并行消费 · 分区分配策略 · 批量处理与背压机制
大规模图谱回放性…并行消费
24
Kafka与图数据库集成
Neo4j/JanusGraph/T…
Kafka图数据库集成
25
回放验证平台化
Web UI设计 · 任务调度（Cron/API触发） · 结果可视化
回放验证平台化Web
26
金融合规与审计
回放日志的不可篡改存储 · 审计追踪 · 监管报告生成
金融合规审计
27
故障演练与容灾
Kafka集群故障模拟 · 回放任务断点续传 · 数据完整性校验
故障演练容灾
28
实战项目1
构建一个简单的金融图谱回放验证系统（…
实战项目1构建一个简单的金…
29
实战项目2
基于Kafka Streams的实时…
实战项目2Kafka
30
课程总结与展望
金融图谱回放验证的未来趋势 · Kafka生态演进 · 学习路径建议
课程总结金融图谱回放验证…