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

信用评分Kafka链路实战资料

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与信用评分业务概述
信用评分在金融风控中的价值 · 实时评分与离线评分的区别 · Kafka在评分链路中的核心定位
课程导学信用评分业务概述
02
Kafka基础概念与集群搭建
Topic · Partition · Broker
Kafka基础概念
03
信用评分数据模型设计
用户画像 · 交易流水 · 外部征信数据的数据结构设计
信用评分数据模型…用户画像
04
Kafka生产者实战
Java/Python Produc… · 同步发送 · 异步发送
Kafka生产者实战
05
Kafka消费者实战
Consumer Group概念 · 订阅与手动提交偏移量 · 再均衡监听器
Kafka消费者实战
06
信用评分事件定义与序列化
使用Avro/Protobuf定义评… · Schema Registry集成 · 兼容性策略
信用评分事件定义序列化
07
Kafka Connect数据接入
使用Source Connector… · Sink Connector写入HD…
KafkaConnect
08
Kafka Streams实时特征计算
使用Kafka Streams DS… · 特征提取 · 状态存储与容错
KafkaStreams
09
KSQL实时评分查询
使用KSQL创建流表 · 实时过滤高风险交易 · 与外部评分模型API联动
KSQL实时评分查询
10
信用评分规则引擎集成
Drools/EasyRules规则… · 规则动态热更新机制
信用评分规则引擎…Drools/EasyR…
11
机器学习模型实时推理
使用PMML/ONNX模型部署 · Kafka消费者调用模型服务进行实时…
机器学习模型实时…PMML/ONNX
12
评分结果回写与下游通知
评分结果写入Kafka结果Topic · 触发告警 · 冻结账户
评分结果回写下游通知
13
Kafka Exactly-Once语义保障
幂等生产者 · 事务性生产者与消费者 · 在评分链路中实现端到端精确一次
KafkaExactly-Once
14
Kafka监控与运维
JMX指标采集 · Prometheus+Grafana… · Lag监控与消费者延迟告警
Kafka监控
15
Kafka安全实践
SSL/TLS加密传输 · SASL/SCRAM认证 · ACL权限控制
Kafka安全实践
16
Kafka集群调优
Broker参数调优（num.par… · log.segment.bytes等… · OS层面优化
Kafka集群调优
17
Kafka与Flink集成实时评分
Flink消费Kafka做复杂事件处… · Flink SQL实时评分
KafkaFlink
18
Kafka与Spark Streaming集成
Structured Streami… · 微批次评分模型更新
KafkaSpark
19
信用评分数据湖架构
Kafka + Hudi/Icebe… · 评分历史数据回溯分析
信用评分数据湖架…Kafka
20
多租户信用评分平台设计
基于Kafka的租户隔离方案 · Topic命名规范 · 资源配额管理
多租户信用评分平…Kafka
21
Kafka消息压缩与批量优化
压缩算法选择（gzip/snappy… · 批量大小与linger.ms调优 · 减少网络开销
Kafka消息压缩
22
Kafka跨集群数据同步
MirrorMaker2配置 · 跨数据中心灾备 · 评分链路高可用设计
Kafka跨集群数据同步
23
信用评分链路压测与性能评估
使用Kafka自带的性能测试工具 · 生产者/消费者吞吐量测试 · 延迟SLA验证
信用评分链路压测性能评估
24
Kafka日志清理与数据保留策略
基于时间/大小的日志保留 · 压缩主题（compact）用于存储用…
Kafka日志清理
25
Kafka REST Proxy与Schema Registry管理
通过REST API生产/消费消息 · Schema版本管理 · 兼容性检查
KafkaREST
26
信用评分异常检测与告警
基于Kafka Streams的实时… · 阈值规则与机器学习异常模型结合
信用评分异常检测告警
27
Kafka与微服务架构集成
使用Spring Kafka/Qua… · 事件驱动架构设计模式
Kafka微服务架构集成
28
Kafka在云原生环境部署
Strimzi Operator部署… · 弹性伸缩与滚动升级
Kafka云原生环境部署
29
信用评分链路全流程实战项目
从数据接入 · 特征计算 · 模型推理到结果下发的完整代码实现
信用评分链路全流…从数据接入
30
课程总结与面试指南
Kafka常见面试题 · 信用评分系统设计要点 · 未来趋势（Kafka + Flink…
课程总结面试指南