2. 事件驱动基础：事件、事件源、事件处理器、事件总线的概念与关系

在构建回测坏账率哨兵架构之前，必须透彻理解事件驱动架构（EDA）的四个核心要素。它们是整个系统的“语言”与“骨架”。本章将逐一拆解这些概念，并阐明它们之间的协作关系。

2.1 核心概念定义

2.2 四要素关系模型

下图展示了事件驱动架构中四个核心要素的静态关系与动态数据流。事件源将事件发布到总线，总线根据路由规则将事件投递给已订阅的事件处理器。

2.3 事件的生命周期与流转

一个事件从产生到被处理，经历四个阶段。理解这个生命周期，有助于设计回测系统的数据一致性策略。

1. 检测与生成：事件源（如账务系统）检测到状态变更（如一笔贷款逾期超过30天），生成事件对象。
2. 序列化与发布：事件被序列化为标准格式（JSON / Avro），通过SDK发布到事件总线的特定Topic。
3. 路由与缓冲：事件总线根据Topic或Routing Key将事件持久化到日志，并推送给所有订阅该Topic的消费者组。
4. 消费与处理：事件处理器（如坏账率计算器）拉取事件，反序列化，执行业务逻辑，可能产生新的事件（级联事件）。

2.4 事件驱动 vs 传统请求驱动

为了更直观地理解事件驱动的优势，下表对比了它与传统REST API请求驱动模式在回测场景下的差异。

2.5 事件总线在回测中的特殊角色

在哨兵架构中，事件总线不仅是通信管道，更是回测引擎的核心存储。它需要具备以下能力：

• 持久化日志：所有历史事件必须持久化，不能丢失。Kafka的日志保留策略（Retention Policy）是关键。
• 偏移量管理：回测时，消费者可以重置偏移量（Offset）到任意历史时间点，实现“时光倒流”。
• 分区顺序保证：同一贷款ID的事件必须发往同一分区，保证处理顺序与历史一致。
• 幂等消费：回测可能重复播放同一事件，处理器必须支持幂等，避免重复计算坏账。

2.6 事件定义规范（回测哨兵标准）

为了保证回测的准确性，每个事件必须包含以下元数据字段。这是哨兵架构的契约标准。

{
  "eventId": "evt_20250321_001234",       // 全局唯一ID
  "eventType": "LoanDefaulted",           // 事件类型（枚举）
  "source": "accounting-service",         // 事件源标识
  "timestamp": 1742544000000,             // 事件发生时间（Unix毫秒）
  "version": 1,                           // 事件Schema版本
  "payload": {                            // 业务负载
    "loanId": "LN202503001",
    "defaultAmount": 150000.00,
    "currency": "CNY",
    "overdueDays": 35
  },
  "tags": {                               // 可扩展标签
    "batchId": "batch_20250321",
    "environment": "production"
  }
}