VIP20
本课程属于：023-信用评分模型在线推理链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

信用评分模型Kafka实时接入教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
信用评分模型实时化的业务背景 · Kafka在实时数据管道中的核心作用 · 本课程学习目标与前置知识要求
课程导论信用评分模型实时…
02
信用评分模型基础
评分卡模型原理 · 常用特征变量（收入 · 负债
信用评分模型基础评分卡模型原理
03
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
04
Kafka集群部署
单机与集群模式搭建 · ZooKeeper/KRaft配置 · 关键参数（replication.f…
Kafka集群部署
05
Kafka命令行操作
创建Topic · 查看Topic详情 · 生产消息
Kafka命令行操作
06
Kafka Java Producer API
创建Producer · 发送消息（同步/异步） · 回调函数
KafkaJava
07
Kafka Java Consumer API
创建Consumer · 订阅Topic · 拉取消息
KafkaJava
08
Kafka Streams入门
Streams DSL基础 · KStream与KTable概念 · 简单过滤与转换操作
KafkaStreams
09
信用评分特征工程概述
常用特征（交易频次 · 金额波动 · 逾期天数）
信用评分特征工程…常用特征
10
Kafka Streams实现滑动窗口特征
使用TimeWindows · 窗口聚合 · 状态存储（State Store）存…
KafkaStreams
11
Kafka Streams实现滚动窗口特征
Tumbling Windows · 每日/每周聚合 · 与滑动窗口的区别
KafkaStreams
12
实时特征计算实战
基于Kafka Streams计算近… · 近7天交易次数 · 最大逾期天数
实时特征计算实战Kafka
13
Kafka Connect介绍
Source Connector与S… · 常用Connector（JDBC · Elasticsearch）
KafkaConnect
14
使用Kafka Connect接入MySQL数据
配置JDBC Source Conn…
KafkaConnect
15
使用Kafka Connect输出到Elasticsearch
配置Elasticsearch Si…
KafkaConnect
16
Avro与Schema Registry
Avro序列化优势 · Schema Registry安装与… · 使用Avro Producer/Co…
AvroSchema
17
Protobuf与Schema Registry
Protobuf定义评分消息结构 · 与Avro对比 · 在Kafka中的使用
ProtobufSchema
18
信用评分模型服务化
模型部署为REST API（Flas… · 模型加载与推理接口设计
信用评分模型服务…REST
19
Kafka Consumer调用评分API
Consumer消费特征消息 · 调用模型API获取分数 · 处理超时与重试
KafkaConsumer
20
评分结果回写Kafka
将模型输出（分数 · 决策 · 时间戳）序列化后写入结果Topic
Kafka评分结果回写
21
实时评分流水线架构总览
数据源 -> Kafka -> St…
实时评分流水线架…Kafka
22
Kafka事务与幂等性
Exactly-Once语义（EOS… · 事务Producer配置 · 防止重复评分
Kafka事务
23
Kafka监控与运维
JMX指标 · Kafka Manager/CMAK · Lag监控
Kafka监控
24
Kafka安全机制
SSL/TLS加密 · SASL/PLAIN认证 · ACL权限控制
Kafka安全机制
25
性能调优
Producer批量发送 · Consumer Fetch大小 · 分区数设计
性能调优Producer
26
容错与高可用
副本机制 · Leader选举 · 消费者Rebalance
容错高可用
27
实时评分延迟优化
减少序列化开销 · 使用直接内存 · 调整poll间隔
实时评分延迟优化减少序列化开销
28
案例实战
搭建端到端实时信用评分系统（模拟数据…
案例实战搭建端到端实时信…
29
测试与质量保障
单元测试（Kafka Streams… · 集成测试（Embedded Kafk… · 压力测试
测试质量保障
30
课程总结与扩展
实时评分最佳实践 · 未来趋势（Flink vs Kafk… · 推荐学习资源
课程总结扩展