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

Kafka驱动的精算模型实时命中复盘案例

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
精算模型实时命中的业务痛点 · Kafka在数据流中的核心价值 · 复盘案例整体架构预览
课程导论精算模型实时命
02
精算模型基础
精算模型定义 · 常见精算模型类型（寿险/非寿险） · 模型输出指标（赔付率
精算模型基础精算模型定义
03
实时命中概念
什么是模型命中 · 实时命中的业务场景（风控 · 定价）
实时命概念
04
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
05
Kafka集群部署
单机与集群模式 · ZooKeeper/KRaft角色 · 副本机制与ISR
Kafka集群部署
06
精算数据源接入
保单数据 · 理赔数据 · 外部征信数据的实时采集方案
精算数据源接入保单数据
07
Kafka Producer设计
精算事件消息格式 · 序列化（Avro/JSON） · 分区策略（按保单号哈希）
KafkaProducer
08
Kafka Consumer设计
消费者组与负载均衡 · 精算模型消费逻辑 · 手动提交偏移量
KafkaConsumer
09
精算模型注册中心
模型版本管理 · 模型元数据（输入特征 · 输出标签）在Kafka中的存储
精算模型注册模型版本管理
10
实时特征工程
特征计算窗口（滑动窗口） · 特征聚合（Kafka Streams… · 特征存储（Redis）
实时特征工程特征计算窗口
11
模型推理引擎
基于Kafka的实时推理架构 · 模型加载与热更新 · 推理结果回写Kafka
模型推理引擎Kafka
12
命中判定逻辑
阈值设定 · 多模型投票 · 规则引擎与模型联合判定
判定逻辑阈值设定
13
复盘数据管道
命中事件 · 未命中事件 · 误报事件的分流与存储（Kafka T…
复盘数据管道事件
14
复盘指标定义
命中率 · 误报率 · 漏报率
复盘指标定义命中率
15
实时监控看板
Kafka消息积压监控 · 模型推理延迟监控 · 命中率趋势图
实时监控看板Kafka
16
复盘数据仓库
从Kafka到HDFS/ClickH… · 分区表设计
复盘数据仓库Kafka
17
复盘分析查询
按时间 · 模型版本 · 业务线维度的命中率聚合查询
复盘分析查询按时间
18
案例一
车险欺诈检测模型实时命中复盘——数据…
案例一车险欺诈检测模型…
19
案例一
车险欺诈检测模型实时命中复盘——命中…
案例一车险欺诈检测模型…
20
案例二
寿险动态定价模型实时命中复盘——特征…
案例二寿险动态定价模型…
21
案例二
寿险动态定价模型实时命中复盘——模型…
案例二寿险动态定价模型…
22
案例三
健康险理赔审核模型实时命中复盘——多…
案例三健康险理赔审核模…
23
案例三
健康险理赔审核模型实时命中复盘——误…
案例三健康险理赔审核模…
24
Kafka Connect集成
使用Kafka Connect连接精…
KafkaConnect
25
Kafka Streams精算应用
状态存储 · 时间窗口 · 聚合操作在命中统计中的应用
KafkaStreams
26
Kafka Schema Registry
Avro Schema演进 · 兼容性检查 · 精算模型特征Schema管理
KafkaSchema
27
容错与高可用
Kafka副本故障转移 · 消费者Rebalance对精算推理的… · 幂等性保证
容错高可用
28
性能调优
精算场景下的Kafka吞吐量调优 · 批量大小 · 压缩算法（Snappy/Zstd）
性能调优Kafka
29
安全与合规
Kafka SSL加密 · SASL认证 · 精算敏感数据脱敏策略
安全合规
30
课程总结与展望
Kafka+精算模型的最佳实践 · 未来趋势（Flink+ Kafka · 实时MLOps）
课程总结Kafka+