ThreeDotsLabs/watermill

Health v2 · maintenance only

Adoption not part of the score

9864 stars · 504 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-29, confidence not recorded

Watermill is a Go library for building event-driven and message-driven applications over a unified Pub/Sub API. It supports Kafka, RabbitMQ, NATS, PostgreSQL, Redis, and more, with routing, middleware, CQRS, sagas, and event sourcing built in.

Use cases

• build event-driven applications in go
• publish and consume messages with kafka or rabbitmq
• implement cqrs and event sourcing in go
• process message streams asynchronously
• implement sagas and outbox pattern
• switch message brokers without changing app code

When to choose

• you want a unified pub/sub abstraction over multiple brokers in Go
• you need event sourcing, CQRS, or sagas without a heavy framework
• you want middleware-based message routing similar to an HTTP router

When to avoid

• you need a full message broker itself rather than a client library
• your project is not in Go
• you need exactly-once delivery guarantees out of the box

Facets

library · maturity active

message-queue streaming middleware serialization rpc workflow-automation backend microservices developer-tools apis go cross-platform cloud event-driven event-sourcing cqrs sagas pub-sub kafka rabbitmq nats stream-processing reactive messaging docker kubernetes

Member repositories

For agents

markdown · JSON · MCP: product_card(name="ThreeDotsLabs/watermill")