VIP20

本课程属于：047-实时交易风控人群切片复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Kafka实时交易风控数据流实战

共计 30 章节

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

课程导论与风控背景

实时交易风控的重要性 · 常见欺诈场景（盗刷 · 薅羊毛

课程导论风控背景

Kafka核心概念速览

Topic · Partition · Producer

Kafka核心概念速览

Kafka集群环境搭建

单机与集群模式部署 · ZooKeeper/KRaft模式对… · 关键配置参数（acks

Kafka集群环境搭建

交易数据模型设计

标准交易事件JSON Schema设… · 用户ID · 金额

交易数据模型设计JSON

Kafka Producer实战

Java/Python Produc… · 异步发送 · 回调处理

Kafka Consumer实战

订阅与拉取模式 · 手动提交offset · 幂等消费与精确一次语义（EOS）配置

Kafka Connect与数据接入

使用Kafka Connect JD… · 实现CDC

Kafka Streams基础

Streams DSL入门 · KTable与KStream转换 · 状态存储（State Store）概…

实时风控规则引擎设计

基于Drools/Flink CEP… · 规则热更新机制 · 规则优先级与冲突处理

实时风控规则引擎…Drools/Flink

Flink与Kafka集成

Flink作为Kafka Consu… · Flink Checkpoint与K… · 端到端一致性

交易特征计算

滑动窗口统计（1分钟/5分钟交易频次 · 金额聚合） · 用户画像特征实时更新

交易特征计算滑动窗口统计

设备指纹与关联图谱

基于Kafka流构建设备-用户-IP… · 实时图数据库（Neo4j/Tiger…

设备指纹关联图谱

黑白名单与缓存策略

Redis缓存黑白名单 · Kafka流与Redis交互 · 布隆过滤器防缓存穿透

黑白名单缓存策略

实时模型推理

集成TensorFlow/PMML模… · Kafka流调用模型服务（gRPC/… · 模型版本管理

实时模型推理TensorFlow/P…

风控决策树实现

基于Kafka Streams实现决… · 分支合并 · 最终决策输出（通过/拒绝/人工审核）

风控决策树实现Kafka

异常检测算法实战

基于Kafka流实现Z-score · 移动平均 · 孤立森林等轻量级异常检测

异常检测算法实战Kafka

多流Join与关联分析

Kafka Streams Join… · KTable-KTable Join… · 交易流与账户流关联

死信队列与异常处理

Kafka死信主题（DLT）设计 · 重试机制 · 错误事件归档与告警

死信队列异常处理

风控结果回写与闭环

风控决策结果写入Kafka · 下游系统（交易系统 · 通知系统）消费结果

风控结果回写闭环

Kafka监控与运维

JMX指标监控 · Lag监控 · Cruise Control集群重平…

数据脱敏与合规

Kafka消息字段脱敏（AES/To… · 审计日志 · GDPR合规要求

数据脱敏合规

性能调优实战

Producer/Consumer参… · linger.ms · fetch.min.bytes）

性能调优实战Producer/Con…

Kafka安全机制

SSL/TLS加密 · SASL认证（PLAIN/SCRAM… · ACL权限控制

Kafka安全机制

多数据中心部署

Kafka MirrorMaker… · 灾备切换 · 全局风控数据汇聚

多数据心部署

实时风控大屏可视化

Kafka流输出到Elasticse… · 实时展示交易量 · 拒绝率

实时风控大屏可视…Kafka

混沌工程与压力测试

使用Chaos Mesh/Litmu… · 验证风控系统韧性 · 性能基准测试

混沌工程压力测试

全链路追踪

基于OpenTelemetry的Ka… · Span关联 · 延迟瓶颈分析

全链路追踪OpenTelemetr…

电商支付风控

案例实战电商支付风控

银行转账反洗钱：大额交易监控 · 可疑模式识别 · 监管报告生成

案例实战银行转账反洗钱

课程总结与未来展望

Kafka + Flink + AI… · Serverless Kafka · 云原生风控架构演进

课程总结未来展望