VIP20
本课程属于：047-实时交易风控人群切片复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka与Flink CEP风控数据流实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学
风控场景概述 · 实时风控技术选型 · Kafka+Flink CEP架构总…
课程导学风控场景概述
02
Kafka核心概念
Topic · Partition · Broker
Kafka核心概念
03
Kafka集群搭建与配置
单机与集群部署 · ZooKeeper依赖 · 关键参数调优
Kafka集群搭建
04
Kafka生产者实战
发送模式 · 分区策略 · 序列化器
Kafka生产者实战
05
Kafka消费者实战
消费模式 · 偏移量提交 · 再均衡监听器
Kafka消费者实战
06
Kafka高级特性
日志压缩 · 时间戳提取器 · Kafka Streams简介
Kafka高级特性
07
Flink基础入门
Flink架构 · 运行环境 · DataStream API概览
Flink基础入门
08
Flink时间语义与Watermark
EventTime · ProcessingTime · IngestionTime
FlinkWatermark
09
Flink状态管理与容错
Keyed State · Operator State · Checkpoint
Flink状态管理
10
Flink窗口操作
Tumbling Window · Sliding Window · Session Window
Flink窗口操作
11
Flink CEP概念与原理
事件模型 · 模式定义 · 模式序列
FlinkCEP
12
Flink CEP模式API详解
Pattern API · 条件（where/or/until） · 量词（oneOrMore/times…
FlinkCEP
13
Flink CEP实战
登录异常检测（连续失败N次） · 交易风控（大额转账+异地登录）
FlinkCEP
14
Flink CEP高级模式
组合模式 · 循环模式 · 超时处理
FlinkCEP
15
Flink与Kafka集成
FlinkKafkaConsumer · FlinkKafkaProducer · 反序列化器
FlinkKafka
16
Flink与Kafka精确一次语义
两阶段提交 · Kafka事务 · FlinkKafkaExactlyO…
FlinkKafka
17
风控数据模型设计
事件定义 · 用户画像标签 · 规则引擎数据流
风控数据模型设计事件定义
18
实时特征计算
滑动窗口计数 · 时间衰减统计 · 布隆过滤器
实时特征计算滑动窗口计数
19
规则引擎架构
规则定义语言 · 规则编译 · 规则评估
规则引擎架构规则定义语言
20
CEP规则与规则引擎结合
将业务规则转化为CEP模式 · 动态模式生成
CEP规则
21
风控数据流Pipeline实战
数据采集→Kafka→Flink C…
Pipeline风控数据流
22
告警与处置模块
告警分级 · 通知渠道（短信/邮件/Webhook… · 自动阻断策略
告警处置模块
23
风控系统监控与运维
Flink作业监控 · Kafka监控 · 延迟告警
风控系统监控运维
24
性能优化
Kafka吞吐量调优 · Flink并行度设置 · 状态后端选择
性能优化Kafka
25
数据一致性保障
去重机制 · 乱序处理 · 幂等写入
数据一致性保障去重机制
26
多场景风控实战
账户盗用检测 · 刷单识别 · 恶意注册
多场景风控实战账户盗用检测
27
Flink SQL在风控中的应用
动态规则 · 维表关联 · 窗口聚合
FlinkSQL
28
Flink CEP与机器学习模型集成
模型服务调用 · 特征向量实时计算 · 模型结果融合
FlinkCEP
29
项目实战
搭建完整风控Demo（模拟交易流 · 规则配置 · 实时告看板）
项目实战Demo
30
课程总结与展望
实时风控趋势 · Flink 2.0新特性 · Kafka生态演进
课程总结实时风控趋势