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

金融知识图谱Kafka集成教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
金融知识图谱概述 · Kafka在金融数据流中的角色 · 课程目标与前置知识
课程导论金融知识图谱概述
02
金融知识图谱基础
实体 · 关系 · 属性定义
金融知识图谱基础实体
03
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
04
Kafka安装与集群部署
单机模式 · 伪集群模式 · 生产环境集群配置要点（Linux环境…
Kafka安装
05
Kafka命令行操作
创建Topic · 查看Topic详情 · 生产消息
Kafka命令行操作
06
Java/Python Producer API
同步发送 · 异步发送 · 回调函数
Java/PythonProducer
07
Java/Python Consumer API
订阅模式 · 手动提交偏移量 · 自动提交
Java/PythonConsumer
08
Kafka消息可靠性保证
ACK机制 · 幂等性 · 事务
Kafka消息可靠性保证
09
Kafka Streams入门
流处理概念 · WordCount示例 · 状态存储与窗口操作
KafkaStreams
10
金融数据采集场景
实时行情数据（股票/期货）接入Kaf…
金融数据采集场景Kaf
11
金融数据清洗与标准化
使用Kafka Streams对交易… · 格式校验 · 字段映射
金融数据清洗标准化
12
知识图谱构建流程
数据源（结构化/非结构化）→ NER…
知识图谱构建流程NER
13
基于Kafka的实时NER管道
使用Spark Streaming或… · 调用NLP模型抽取实体
KafkaNER
14
关系抽取与事件抽取
金融事件（并购 · 财报发布）的实时抽取与Kafka消息…
关系抽取事件抽取
15
知识融合与实体对齐
基于Kafka的增量对齐策略 · 解决同名实体 · 同义实体问题
知识融合实体对齐
16
图数据库选型与集成
Neo4j · JanusGraph · Nebula Graph对比
图数据库选型集成
17
Kafka Connect实战
使用JDBC Source Conn…
KafkaConnect
18
Kafka Connect Sink
将清洗后的知识三元组写入Neo4j（…
KafkaConnect
19
实时知识图谱更新
基于Kafka消息的增量更新策略 · 避免全量重建
实时知识图谱更新Kafka
20
金融风控场景实战
实时构建客户关联图谱 · 检测循环担保 · 团伙欺诈
金融风控场景实战实时构建客户关联…
21
反洗钱（AML）场景
利用Kafka流处理实时计算交易链路 · 识别可疑交易模式
AML反洗钱
22
智能投顾场景
实时知识图谱辅助资产配置推荐 · Kafka作为事件总线
智能投顾场景实时知识图谱辅助…
23
监管科技（RegTech）
基于Kafka的实时合规检查 · 如持仓限额 · 交易报告
RegTech监管科技
24
Kafka监控与运维
JMX指标 · Cruise Control · Kafka Manager
Kafka监控
25
性能调优
分区数优化 · 批量大小 · 压缩算法
性能调优分区数优化
26
数据治理与血缘
使用Kafka Schema Reg… · 追踪数据血缘
数据治理血缘
27
安全与权限控制
SSL/TLS加密 · SASL认证 · ACL授权在金融场景下的配置
安全权限控制
28
灾难恢复与多活架构
Kafka MirrorMaker… · 金融级高可用设计
灾难恢复多活架构
29
综合项目实战（上）
搭建实时金融知识图谱管道——从行情A…
综合项目实战搭建实时金融知识…
30
综合项目实战（下）
构建可视化知识图谱查询界面 · 集成Kafka消息回溯与历史重放功能
综合项目实战构建可视化知识图…