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

Kafka实时图谱构建教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与图谱基础
什么是知识图谱 · 实时图谱的应用场景（风控 · 推荐
课程导论图谱基础
02
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
03
Kafka集群部署
单机与集群模式安装 · ZooKeeper/KRaft模式对… · 常用配置参数详解
Kafka集群部署
04
Kafka生产者深入
发送流程 · 分区策略 · acks与retries
Kafka生产者深入
05
Kafka消费者深入
消费模式 · Rebalance机制 · 位移提交（自动/手动）
Kafka消费者深入
06
Kafka高级特性
消息压缩 · 日志清理策略 · Exactly-Once语义
Kafka高级特性
07
Kafka监控与运维
JMX监控 · Kafka Eagle/Burrow · 常见故障排查（日志积压
Kafka监控
08
图数据库Neo4j入门
图模型（节点 · 关系 · 属性）
Neo4j图数据库
09
Neo4j数据建模
节点标签设计 · 关系类型设计 · 属性索引与约束
Neo4j数据建模
10
Neo4j批量导入
LOAD CSV · APOC插件 · neo4j-admin import…
Neo4j批量导入
11
实时计算Flink基础
Flink架构 · DataStream API · 时间语义（Event Time/Pr…
Flink实时计算
12
Flink与Kafka集成
Flink Kafka Connec… · Source/Sink配置 · Exactly-Once保证
FlinkKafka
13
Flink状态管理与容错
Keyed State · Operator State · Checkpoint与Savepoi…
Flink状态管理
14
Flink CEP（复杂事件处理）
Pattern API · 事件序列匹配 · 超时与跳过策略
FlinkCEP
15
实时图谱构建架构设计
Lambda架构 vs Kappa架… · 数据流管道设计（Kafka→Flin…
实时图谱构建架构…Lambda
16
数据接入层设计
定义图谱事件Schema（Avro/… · Kafka Topic规划 · 事件序列化与反序列化
数据接入层设计Schema
17
Flink实时ETL与实体抽取
从Kafka消费原始事件 · 解析JSON · 提取实体ID与属性
FlinkETL
18
Flink实时关系抽取
基于规则的关系识别 · 基于Flink CEP的关系模式匹配 · 多流Join
Flink实时关系抽取
19
Flink图更新逻辑
节点与关系的增删改 · 幂等更新设计 · 避免重复边与属性覆盖策略
Flink图更新逻辑
20
Neo4j实时写入优化
批量写入（Batch Ingest） · 异步写入 · 连接池管理
Neo4j实时写入优化
21
实时图谱的时序与版本管理
事件时间戳处理 · 属性历史版本 · 图快照与回溯查询
实时图谱的时序版本管理
22
实时图谱的增量更新与一致性
最终一致性保证 · 冲突解决 · 死信队列处理
实时图谱的增量更…一致性
23
实时图谱查询服务
基于Cypher的实时查询接口 · 图遍历优化 · 索引加速
实时图谱查询服务Cypher
24
实时图谱可视化
Neo4j Browser · Gephi集成 · 自定义Web可视化（D3.js/Vi…
实时图谱可视化Neo4j
25
案例实战1
实时风控图谱——从Kafka消费交易… · 构建用户-设备-IP关联图谱 · 识别异常环
案例实战1Kafka
26
案例实战2
实时社交推荐图谱——从Kafka消费… · 构建用户-兴趣-内容图谱 · 实时推荐
案例实战2Kafka
27
案例实战3
实时IT运维图谱——从Kafka消费… · 构建服务-主机-依赖图谱 · 根因分析
案例实战3IT
28
性能压测与调优
Kafka吞吐量调优 · Flink并行度与内存调优 · Neo4j写入与查询性能调优
性能压测调优
29
生产环境部署与高可用
多机房容灾 · Kafka MirrorMaker · Flink HA
生产环境部署高可用
30
课程总结与未来展望
实时图谱的演进趋势（图神经网络 · 流式图计算） · 推荐学习路径
课程总结未来展望