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

Kafka实时特征管道构建方法

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
实时特征管道定义 · Kafka在实时架构中的核心地位 · 课程目标与前置知识
课程导论实时特征管道定义
02
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
03
Kafka集群部署
单机与集群模式 · ZooKeeper/KRaft模式对… · 硬件选型与配置建议
Kafka集群部署
04
Kafka生产者深入
发送模式（同步/异步） · 分区策略 · 消息确认机制（acks）
Kafka生产者深入
05
Kafka消费者深入
消费模式（pull） · 偏移量提交（自动/手动） · 再均衡机制
Kafka消费者深入
06
Kafka消息可靠性
副本机制（ISR） · Leader选举 · 数据持久化与日志压缩
Kafka消息可靠性
07
Kafka性能调优
批量大小 · 压缩算法（gzip/snappy/l… · 缓冲区配置
Kafka性能调优
08
Kafka Streams入门
流处理概念 · KStream与KTable · 状态存储
KafkaStreams
09
Kafka Streams实战
实时特征聚合（计数 · 求和 · 平均值）
KafkaStreams
10
Kafka Connect基础
Source Connector与S… · 单机与分布式模式 · REST API管理
KafkaConnect
11
Kafka Connect实战
从MySQL CDC同步数据到Kaf… · 从Kafka写入Elasticsea…
KafkaConnect
12
Schema Registry
Avro/Protobuf/JSON… · 序列化与反序列化 · Schema演化兼容性
SchemaRegistry
13
KSQL简介
流式SQL语法 · 创建流与表 · 持续查询
KSQL简介
14
KSQL实战
使用KSQL构建实时特征视图 · 数据过滤与转换 · 窗口聚合
KSQL使用
15
实时特征管道架构设计
Lambda架构与Kappa架构 · 事件时间与处理时间 · 水印与延迟
实时特征管道架构…Lambda
16
特征存储系统
特征存储概念 · 在线特征与离线特征 · 与Kafka的集成模式
特征存储系统特征存储概念
17
实时特征计算引擎
Fink与Kafka集成 · Spark Streaming与Ka… · 对比选型
实时特征计算引擎Fink
18
Flink Kafka Connector
Flink Source/Sink · 检查点与精确一次语义 · 动态分区发现
FlinkKafka
19
Flink实时特征计算实战
滑动窗口特征 · 会话窗口特征 · 自定义触发器
Flink实时特征计算实战
20
特征管道监控与运维
Kafka监控指标（JMX） · Lag监控 · 告警策略
特征管道监控运维
21
数据质量保障
特征数据校验 · 异常检测 · 死信队列
数据质量保障特征数据校验
22
特征管道安全
SSL/TLS加密 · SASL认证 · ACL权限控制
特征管道安全SSL/TLS
23
多租户特征管道
Topic命名规范 · 资源隔离 · 配额管理
多租户特征管道Topic
24
特征管道CI/CD
Schema版本管理 · 管道代码测试 · 灰度发布
CI/CD特征管道
25
特征管道数据湖集成
Kafka与Hudi/Iceberg… · 实时入湖
特征管道数据湖集…Kafka
26
特征管道与机器学习
实时特征服务 · 特征重要性监控 · 模型在线更新
特征管道机器学习
27
特征管道最佳实践
消息键设计 · 分区数规划 · 重试与幂等设计
特征管道最佳实践消息键设计
28
特征管道故障排查
常见问题（消息丢失 · 重复消费 · OOM
特征管道故障排查常见问题
29
特征管道案例一
实时推荐系统特征管道（用户行为采集 · 实时画像 · 特征拼接）
特征管道案例一实时推荐系统特征…
30
特征管道案例二
实时风控系统特征管道（交易事件流 · 规则引擎 · 特征计算）
特征管道案例二实时风控系统特征…