VIP20
本课程属于：059-保险精算模型规则命中复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka实时数据精算模型命中复盘指南

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
什么是精算模型命中复盘？为什么需要基…
课程导论什么是精算模型命
02
Kafka核心概念回顾
Topic · Partition · Consumer Group
Kafka核心概念回顾
03
精算模型基础
精算模型在风控/保险/金融中的典型应… · 模型命中定义与业务含义
精算模型基础精算模型
04
实时数据流架构
从数据采集到模型推理再到结果回传的端…
实时数据流架构从数据采集到模型…
05
Kafka作为事件总线
如何利用Kafka解耦模型服务与业务… · 实现高吞吐低延迟
Kafka作为事件总线
06
模型命中事件定义
设计标准化的命中事件Schema（事… · 时间戳 · 模型版本
模型命事件定义
07
Avro与Schema Registry
使用Avro序列化命中事件 · 通过Schema Registry管…
AvroSchema
08
Kafka Producer最佳实践
幂等生产者 · 事务 · 批量发送
KafkaProducer
09
Kafka Consumer最佳实践
消费者组再均衡 · 位移提交策略（自动/手动） · 并发消费模型
KafkaConsumer
10
实时特征计算
基于Kafka Streams/KS…
实时特征计算Kafka
11
模型服务集成
将Kafka消息路由到模型推理服务（… · ONNX Runtime）的架构模式
模型服务集成Kafka
12
命中结果回写
模型输出结果写回Kafka · 形成完整的命中事件闭环
结果回写Kafka
13
复盘数据湖构建
使用Kafka Connect将命中…
复盘数据湖构建Kafka
14
命中率统计与监控
基于Kafka消息实时计算分钟级/小… · 配置告警规则
率统计监控
15
时间戳对齐与延迟分析
处理事件时间与处理时间偏差 · 利用Kafka时间戳提取器进行水位线…
时间戳对齐延迟分析
16
数据回溯与重放
利用Kafka消息的持久化特性 · 对历史命中事件进行回溯重放以验证模型…
数据回溯重放
17
版本对比复盘
同时消费新旧两个模型版本的命中事件T… · 对比命中率 · 分布差异
版本对比复盘同时消费新旧两个…
18
异常检测与漂移监控
实时监控特征分布漂移（PSI） · 命中率突变 · 通过Kafka告警通知
异常检测漂移监控
19
多维度下钻分析
按渠道 · 用户群 · 时间窗口等维度对命中事件进行实时聚合…
多维度下钻分析按渠道
20
Kafka集群运维要点
分区数规划 · 副本因子 · ISR管理
Kafka集群运维要点
21
性能调优实战
调整batch.size · linger.ms · compression.type等参…
性能调优实战batch.size
22
数据一致性保障
Exactly-Once语义在精算模…
数据一致性保障Exactly-Once
23
安全与权限控制
使用SASL/SSL加密Kafka通… · 配置ACL限制模型命中Topic的访…
安全权限控制
24
可视化复盘看板
使用Grafana + Promet…
可视化复盘看板Grafana
25
案例实战一
信贷风控模型实时命中复盘——从数据接…
案例实战一信贷风控模型实时…
26
案例实战二
保险精算定价模型实时命中复盘——特征…
案例实战二保险精算定价模型…
27
案例实战三
实时推荐系统模型命中复盘——A/B实…
案例实战三A/B
28
常见问题与排错
Consumer Lag飙升 · 消息积压 · 序列化异常
常见问题排错
29
复盘报告自动化
基于Kafka消息生成每日/每周复盘… · 通过邮件或钉钉机器人推送
复盘报告自动化Kafka
30
课程总结与展望
实时精算模型复盘的未来趋势（Flin… · 云原生 · AI辅助复盘）
课程总结Flin