1. 课程导学：实时风控背景、Kafka在风控中的核心价值、课程目标与前置知识

1.1 实时风控的时代背景

在数字化转型浪潮中，金融交易、电商支付、账户登录等业务场景正以毫秒级速度产生海量事件。传统的离线风控系统（T+1 批量处理）已无法应对以下挑战：

• 攻击速度升级：黑产团伙利用自动化工具在数秒内发起撞库、薅羊毛、洗钱等攻击。
• 数据体量爆炸：头部互联网平台日均风控事件量级可达百亿条，传统数据库无法承载。
• 决策时效要求：支付、转账等场景要求风控决策在 100ms 内完成，否则影响用户体验。
• 规则与模型迭代：欺诈模式快速演变，风控策略需要分钟级热更新。

1.2 实时风控架构的核心挑战

构建实时风控引擎并非简单地将批处理改为流处理，需要解决以下关键问题：

1.3 Kafka 在风控中的核心价值

Apache Kafka 作为分布式事件流平台，天然适配实时风控场景。其核心价值体现在以下四个维度：

1. 高吞吐、低延迟的消息管道：单集群可支撑百万级 TPS，端到端延迟毫秒级，满足风控事件采集与分发需求。
2. 持久化与回溯能力：消息落盘到磁盘，支持按偏移量或时间戳回溯消费，便于模型训练、策略回测与故障恢复。
3. 解耦与异步削峰：风控引擎各模块（采集、特征、决策、处置）通过 Topic 解耦，流量洪峰时由 Kafka 缓冲，避免系统雪崩。
4. 流式处理生态：与 Flink、Spark Streaming、Kafka Streams 无缝集成，支持在消息管道内直接完成特征计算与规则匹配。

1.4 课程目标

通过本课程，你将掌握以下核心能力：

1.5 前置知识要求

为了获得最佳学习体验，建议你具备以下基础：

• Java 基础：熟悉 Java 8+ 语法、多线程、Lambda 表达式，因为 Kafka 客户端和 Streams API 均基于 Java。
• Linux 基础：能够使用命令行操作文件、查看日志、执行脚本，Kafka 集群部署与调试在 Linux 环境下进行。
• 消息队列概念：了解生产者、消费者、主题、分区等基本概念，有助于快速理解 Kafka 核心模型。
• 风控基础知识（可选）：了解规则引擎、评分卡、设备指纹等概念，但不是必须，课程会从零讲解。

1.6 课程内容概览

本课程共 30 章，分为以下五个模块：