VIP20
本课程属于：016-支付风控策略分群评分沙盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

风险控制实战：Kafka与实时评分沙盘

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风控体系概述
金融风控发展史 · 实时风控的必要性 · 课程整体架构与学习目标
风控体系概述金融风控发展史
02
Kafka核心概念
Topic · Partition · Broker
Kafka核心概念
03
Kafka集群搭建
单机与集群部署 · ZooKeeper/KRaft模式对… · 常用配置参数调优
Kafka集群搭建
04
Kafka生产者实战
发送模式（同步/异步） · 分区策略 · 消息确认机制（acks）
Kafka生产者实战
05
Kafka消费者实战
消费组与再均衡 · 偏移量提交（自动/手动） · 顺序消费与并发消费
Kafka消费者实战
06
Kafka消息可靠性
数据丢失场景分析 · 副本机制（ISR） · 最小同步副本配置
Kafka消息可靠性
07
Kafka Streams入门
流处理概念 · KStream与KTable · 状态存储与窗口操作
KafkaStreams
08
实时评分引擎架构
评分引擎整体设计 · 特征计算层 · 规则引擎层
实时评分引擎架构评分引擎整体设计
09
特征工程基础
实时特征与离线特征区别 · 滑动窗口特征 · 计数/均值/方差等统计特征
特征工程基础实时特征
10
规则引擎设计
规则定义语言（DRL/JSON规则） · 规则编译 · 规则匹配与冲突解决
规则引擎设计DRL/JSON
11
实时评分沙盘搭建
沙盘整体架构设计 · 数据流模拟器 · 评分结果可视化看板
实时评分沙盘搭建沙盘整体架构设计
12
数据模拟器开发
使用Java/Python生成模拟交… · 模拟用户行为序列 · 异常数据注入
数据模拟器开发Java/Python
13
Kafka Connect实战
Source Connector与S… · JDBC连接器 · 文件连接器
KafkaConnect
14
Flink与Kafka集成
Flink作为实时计算引擎 · Flink Kafka Consum… · 事件时间与处理时间
FlinkKafka
15
实时特征计算
基于Flink的滑动窗口聚合 · CEP（复杂事件处理）模式匹配
实时特征计算Flink
16
评分模型部署
模型序列化（PMML/ONNX） · 模型热加载 · 模型版本管理
评分模型部署PMML/ONNX
17
规则与模型融合
规则前置过滤 · 模型评分后处理 · 规则与模型权重动态调整
规则模型融合
18
实时决策树
决策树在风控中的应用 · 实时决策树推理引擎 · 特征分裂点优化
实时决策树决策树
19
风控变量存储
Redis实时特征存储 · HBase历史特征存储 · 特征TTL与过期策略
风控变量存储Redis
20
Kafka与Redis集成
Kafka消息触发Redis更新 · Redis作为Kafka消息缓存 · 读写性能优化
KafkaRedis
21
实时监控与告警
Kafka监控指标（Lag/Thro… · Prometheus+Grafana… · 自定义告警规则
实时监控告警
22
数据血缘与回溯
Kafka消息回溯机制 · 数据血缘追踪 · 离线重算与实时校正
数据血缘回溯
23
压力测试与性能调优
Kafka吞吐量压测 · 消费者Lag优化 · 分区数调整与Rebalance优化
压力测试性能调优
24
多租户风控架构
租户隔离策略 · Topic命名规范 · 资源配额管理
多租户风控架构租户隔离策略
25
实时风控安全
Kafka ACL权限控制 · SSL/TLS加密 · 数据脱敏与审计日志
实时风控安全Kafka
26
异常检测实战
基于统计的异常检测（3-Sigma · IQR） · 基于机器学习的异常检测（Isolat…
异常检测实战Sigma
27
实时黑名单服务
黑名单存储与查询（Redis/Blo… · Kafka消息驱动黑名单更新
实时黑名单服务Redis/Blo
28
评分结果分发
Kafka Sink到业务系统 · WebSocket实时推送 · 回调接口设计
评分结果分发Kafka
29
沙盘综合演练
端到端实时评分流程演示 · 模拟攻击与防御 · 评分结果分析
沙盘综合演练端到端实时评分流…
30
课程总结与进阶
常见问题复盘 · 生产环境踩坑经验 · 推荐学习资源与社区
课程总结进阶