VIP20
本课程属于：047-实时交易风控人群切片复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka实时交易风控人群切片实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
实时风控背景 · 人群切片概念 · Kafka在风控中的核心价值
课程导论实时风控背景
02
风控基础
交易风控常见场景（盗刷 · 欺诈 · 洗钱）
风控基础交易风控常见场景
03
Kafka核心概念回顾
Topic · Partition · Consumer Group
Kafka核心概念回顾
04
Kafka集群部署与调优
生产环境部署要点 · Broker配置 · 副本因子
Kafka集群部署
05
Kafka生产者深入
发送模式（同步/异步） · acks配置 · 重试机制
Kafka生产者深入
06
Kafka消费者深入
消费模式（pull） · offset提交方式（自动/手动） · 再均衡监听器
Kafka消费者深入
07
Kafka Streams入门
Streams DSL · KTable与KStream · 状态存储
KafkaStreams
08
人群切片概念与设计
什么是人群切片 · 切片维度（用户ID · 设备指纹
人群切片概念设计
09
实时交易数据模型设计
交易事件Schema设计（JSON/… · 关键字段（金额 · 时间
实时交易数据模型…Schema
10
Schema Registry集成
Avro与Schema Regist… · 注册与兼容性策略 · 在Kafka生产/消费中使用
SchemaRegistry
11
风控规则引擎基础
规则定义（阈值规则 · 频率规则 · 黑白名单）
风控规则引擎基础规则定义
12
基于Kafka Streams的实时规则计算
使用KStream实现滑动窗口计数 · 金额累加 · 异常检测
KafkaStreams
13
人群切片状态存储
使用Kafka Streams的状态…
人群切片状态存储Kafka
14
多维度切片聚合
按用户 · 设备 · IP三个维度同时聚合
多维度切片聚合按用户
15
复杂事件处理（CEP）入门
CEP概念 · 与Kafka Streams结合 · 检测序列模式（如短时间多笔大额）
CEP复杂事件处理
16
风控模型集成
将离线训练的模型（如XGBoost）… · 在Kafka Streams中调用模…
风控模型集成XGBoost
17
实时特征工程
基于Kafka Streams计算滑… · 平均金额 · 标准差）
实时特征工程Kafka
18
Kafka Connect数据集成
使用Source Connector… · 日志文件） · Sink Connector输出结果…
KafkaConnect
19
风控结果输出与告警
将风控决策结果（通过/拒绝/人工审核… · 触发告警通知
风控结果输出告警
20
延迟与吞吐量优化
Kafka参数调优（batch.si… · linger.ms · compression）
延迟吞吐量优化
21
数据去重与幂等性
交易幂等性设计 · Kafka生产者幂等性 · 消费者去重方案（基于状态存储）
数据去重幂等性
22
容错与高可用
Kafka副本机制 · Streams任务故障恢复 · Exactly-Once语义实现
容错高可用
23
监控与告警体系
Kafka监控指标（Lag · 吞吐量 · ISR）
监控告警体系
24
实战项目架构设计
整体架构图（数据源->Kafka->… · 模块划分 · 技术选型
实战项目架构设计Kafka
25
实战环境搭建
Docker Compose部署Ka… · Schema Registry · Kafka Connect
实战环境搭建Docker
26
实战
交易数据模拟与接入 · 使用Avro序列化发送到Kafka
交易数据模拟接入
27
实战
实现人群切片规则引擎
实现人群切片规则…重点
28
实战
多维度切片聚合与状态查询 · 并通过交互式查询（IQ）查询当前状态
多维度切片聚合状态查询
29
实战
模型推理与决策输出 · 将评分结果与规则结果合并输出
模型推理决策输出
30
课程总结与进阶方向
课程回顾 · 常见问题与解决方案 · 未来方向（Flink vs Kafk…
课程总结进阶方向