Danube is an open-source, distributed messaging broker system, built in Rust
Danube aims to be a lightweight yet powerful, secure and scalable messaging platform, suitable for event-driven applications. Sub-second dispatch + cloud economics. Self-contained brokers with embedded Raft consensus. Two modes: best-effort pub/sub or at-least-once streaming with WAL + object storage
Zero external dependencies, metadata replicated across brokers via embedded Raft consensus (openraft), data persisted in a local WAL with pluggable durable storage (shared filesystem, or S3/GCS/Azure via OpenDAL). Scale horizontally by adding brokers; topics rebalance automatically with durable history accessible from any node in shared-storage modes.
Intelligent load management continuously monitors broker health and automatically rebalances topics to prevent hotspots. New topics land on the least-loaded broker. Workload changes? The cluster adapts without manual intervention.
Manage your cluster through natural language with Claude, Cursor, or Windsurf. Intelligent tools accessible via Model Context Protocol (MCP): create topics, analyze lag, troubleshoot issues, query metrics, all by conversation. CLI, Web UI, or AI: your choice.
- Non-Reliable: Zero persistence, sub-millisecond latency for real-time metrics and live telemetry
- Reliable: At-least-once delivery with WAL persistence, optionally backed by cloud durable storage for cross-broker history and infinite retention
Centralized schema versioning with compatibility enforcement across JSON Schema, Avro, and Protobuf. Prevent schema drift and invalid messages before they reach consumers. Single source of truth for your data contracts.
Plug-and-play integrations with MQTT, databases, Kafka, ClickHouse, vector databases, and more. Framework isolated from broker core, build connectors without touching cluster internals.
- danube - The messaging broker, a lightweight, cloud‑native messaging platform built in Rust.
- danube-connect-core - Core SDK for building high-performance connectors
- danube-connectors - Available connectors for Danube Messaging
- danube-cli - Command-line companion for interacting with Danube messaging system
- danube-admin - Unified admin tool (CLI + AI/MCP + Web UI)
- 🦀 danube-client - Danube Rust client library (SDK)
- 🐹 danube-go - Danube Go client library (SDK)
- ♨️ danube-java - Danube Java client library (SDK)
- 🐍 danube-py - Danube Python client library (SDK)
- Documentation - Architecture, concepts, and guides
- Getting Started - Deploy your first cluster
- Client Libraries - Rust and Go SDKs
- Schema Registry - Type-safe messaging
- ⭐ Star the repo - Show your support!
- 🐛 Report issues - Help us improve
- 💡 Contribute - PRs welcome across all repos
- 📣 Join discussions - Share ideas and feedback