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

Kafka实时评分沙盘构建教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
实时评分沙盘的概念 · 应用场景（风控 · 游戏
课程导论实时评分沙盘的概…
02
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
03
Kafka集群搭建
单机与集群模式部署 · ZooKeeper/KRaft配置 · 启动与验证
Kafka集群搭建
04
Kafka命令行操作
创建Topic · 查看描述 · 生产消息
Kafka命令行操作
05
Kafka Java Producer API
同步发送 · 异步发送 · 回调
KafkaJava
06
Kafka Java Consumer API
订阅模式 · Assign模式 · 位移提交（自动/手动）
KafkaJava
07
Kafka Streams入门
流处理概念 · KStream/KTable · 状态存储
KafkaStreams
08
Kafka Connect基础
Source Connector与S… · FileStream Connect…
KafkaConnect
09
实时评分模型设计
评分因子定义 · 权重分配 · 滑动窗口聚合
实时评分模型设计评分因子定义
10
评分沙盘架构设计
整体架构图（数据采集层 · 流处理层 · 评分计算层
评分沙盘架构设计整体架构图
11
数据采集层实现
使用Kafka Connect采集M…
数据采集层实现Kafka
12
流处理引擎选型
Kafka Streams vs F… · 本课程选用Kafka Streams…
流处理引擎选型Kafka
13
评分事件定义
Avro/Protobuf Sche… · 事件字段（用户ID · 行为类型
评分事件定义Avro/Protobu…
14
实时ETL清洗
过滤无效事件 · 字段补全 · 格式标准化
ETL实时
15
滑动窗口评分计算
基于Kafka Streams的Ho… · 每5分钟更新一次评分
滑动窗口评分计算Kafka
16
多维度评分聚合
按用户 · 按行为类型 · 按时间段进行sum/count/av…
多维度评分聚合按用户
17
评分衰减机制
时间衰减函数实现（指数衰减 · 线性衰减） · 历史权重逐渐降低
评分衰减机制时间衰减函数实现
18
规则引擎集成
将评分结果输入Drools或自研规则… · 触发阈值告警
规则引擎集成Drools
19
状态存储与容错
Kafka Streams状态存储（… · Changelog Topic · Exactly-Once语义
状态存储容错
20
评分结果输出
将最终评分写入Kafka结果Topi… · 供下游消费
评分结果输出Kafka
21
实时可视化层
使用WebSocket将评分推送到前… · ECharts实时折线图/仪表盘展示
实时可视化层WebSocket
22
沙盘模拟器构建
模拟用户行为数据生成器（随机事件 · 突发流量 · 异常行为）
沙盘模拟器构建模拟用户行为数据…
23
沙盘监控与运维
Kafka监控（JMX · Burrow · Kafka Manager）
沙盘监控运维
24
性能调优
Producer/Consumer参… · 分区数调整 · 批量大小
性能调优Producer/Con…
25
数据一致性保障
幂等Producer · 事务API · 读已提交隔离级别
数据一致性保障Producer
26
多租户评分沙盘
基于Consumer Group隔离… · Topic命名规范
多租户评分沙盘Consumer
27
单元测试与集成测试
Kafka Streams Topo… · MockProducer/MockC…
单元测试集成测试
28
CI/CD流水线
Docker化部署 · Kubernetes编排 · 自动化测试与滚动升级
CI/CD流水线
29
实战案例1
电商实时用户忠诚度评分沙盘（浏览 · 加购 · 下单
实战案例1电商实时用户忠诚…
30
实战案例2
游戏实时反作弊评分沙盘（登录频率 · 金币异常 · 行为序列异常检测）
实战案例2游戏实时反作弊评…