全球企业正在抛弃"事后诸葛亮"式的批处理分析。欺诈检测、实时客户体验、物联网监控、支付系统——这些场景里，事件驱动架构（EDA）早已不是时髦的集成模式，而是实时数据平台的核心积木。

根源很现实：批处理的问题往往不是技术，而是时机。数据被采集、搬运、处理、上报，等业务拿到结果，决策窗口可能已经关闭。EDA的正确设计能压缩这个延迟，让数据随事件流动即时处理，实现更低延迟、更快响应、更灵活的集成。

打开网易新闻 查看精彩图片

但别误会，EDA不是要取代批处理。海量历史数据处理、周期性报表、财务关账、重型批量转换，这些仍是批处理的强项。EDA真正的价值在于数据持续流动、决策必须秒级做出、系统需要即时反应的场景。

打开网易新闻 查看精彩图片

设计糟糕的EDA会把流处理变成数据平台的灾难。起初"开个Kafka主题让系统往里写"看似简单，几个月后可能演变成：主题无序膨胀、事件归属模糊、数据分发不可靠、消费者依赖纠缠、重处理噩梦、数据流难以追踪。

本系列围绕两个核心问题：如何设计一个事件？事件如何在平台内演进成熟？本文聚焦事件本身——事件与命令的区别、Kafka主题/通道模型、Schema契约、分区键、生产者-消费者关系，以及常见设计陷阱。下篇将探讨事件在平台内的生命周期：从原始事件到精炼事件的管道、死信队列（DLQ，存放处理失败或无法解析事件的通道）与告警主题、重放、监控、治理，以及与现代湖仓架构中Medallion模型的关系。

打开网易新闻 查看精彩图片

EDA的本质是系统通过事件而非直接同步调用来通信。事件代表系统中已发生的、有意义的业务事实：客户被创建、支付已完成、卡片交易失败、库存跌破阈值。这些事实已经发生，不可撤销，系统基于它们做出反应。