watermill

Watermill 是一个用于构建事件驱动应用的 Go 语言消息流处理库。它提供统一的抽象层，支持 Kafka、NATS、RabbitMQ 等主流消息中间件，也兼容 HTTP 和 PostgreSQL 等非传统消息源；内置对 CQRS、事件溯源、Saga 模式、RPC over messages 的原生支持，并具备中间件机制、消息重试、可观测性与高可靠性保障。适用于微服务通信、异步任务调度、数据一致性同步、实时流处理等需要解耦与弹性扩展的后端架构场景。