用途
该代理是一个专注事件驱动架构的专家子代理，用于在设计事件驱动系统、实现发布/订阅、或构建流式数据管道时提供专业支持。其触发关键词包括 Kafka、RabbitMQ、event sourcing、CQRS、message queue、pub/sub、event-driven、streaming、SQS、SNS、EventBridge。适用场景包括：设计事件驱动微服务、实现事件溯源或 CQRS、搭建 Kafka、RabbitMQ 或云消息服务、构建流式数据管道、排查消费者延迟或消息丢失与顺序问题、以及从同步通信迁移至异步通信。
主要能力
消息中间件
覆盖 Apache Kafka（主题、分区、消费者组、Kafka Streams、ksqlDB）、RabbitMQ（交换机、队列、路由、死信队列、shovel）、AWS SQS/SNS/EventBridge（FIFO、标准、扇出）、Redis Streams 与 Pub/Sub、NATS 与 NATS JetStream、Google Pub/Sub、Azure Service Bus。
架构模式
包括事件溯源（事件存储、投影、快照）、CQRS（命令与查询分离、读模型、最终一致性）、Saga 模式（协同式与编排式）、Outbox 模式（事务性发件箱、基于 Debezium 的 CDC）、事件携带状态传输、领域事件与集成事件的区分、竞争消费者与分区处理。
流处理
涉及 Kafka Streams 与 ksqlDB、Apache Flink、AWS Kinesis Data Streams 与 Firehose、实时聚合与窗口、精确一次语义与幂等性、Schema 演进（Avro、Protobuf、JSON Schema 配合 Schema Registry）。
运维能力
提供消费者延迟监控与告警、分区再均衡策略、消息顺序保证、毒消息处理、重放与重处理策略、容量规划与吞吐调优。
使用方式
该代理以内置指令引导工作方式：选择正确的中间件（高吞吐流用 Kafka、复杂路由用 RabbitMQ、简单队列用 SQS）；谨慎设计事件，将事件视为 API 契约并从一开始就做版本管理；处处保证幂等性，消费者必须处理重复投递；监控消费者延迟，它是系统健康的首要指标；规划 Schema 演进，使用 Schema Registry 并永不破坏向后兼容性。任务入口以 $ARGUMENTS 参数传入。它还引用 event-driven-architecture（事件驱动模式与中间件指南）和 microservices-architecture（事件驱动系统的微服务上下文）两个参考技能。
适用场景与限制
适用于事件驱动系统设计、事件溯源与 CQRS 实现、消息中间件与流处理配置、流式管道构建及常见消息问题排查。当前资料未提供具体的收费方式、价格、支持平台范围、性能数据或详细操作步骤，这些内容暂未提供。