Introduction • Features • Architecture • Quick Start • Build Script • Documentation • Contributing • Community
⚠️ Development Status RobustMQ is currently in early preview phase with active development and testing. A stable release is anticipated in Q3-Q4 2025. Our roadmap includes achieving production readiness and pursuing Apache top-level project status.
RobustMQ is a next-generation, high-performance message queue built in Rust, designed for modern cloud-native and AI systems. It unifies MQTT, Kafka, and AMQP protocols with compute-storage separation architecture, enabling microsecond latency and elastic scaling.
Traditional message queues face critical challenges in the AI era: protocol fragmentation requiring multiple systems, latency jitter failing real-time AI needs, compute-storage coupling preventing Serverless deployment, and high costs lacking elastic scaling.
RobustMQ provides a unified messaging platform with flexible architecture that supports all scenarios, eliminating the need to maintain multiple message queue systems.
Vision: Become the next-generation cloud-native and AI-native messaging infrastructure, targeting Apache top-level project status.
- 🚀 High Performance: Rust-powered zero-cost abstractions with microsecond latency and zero GC pauses
- 🏗️ Compute-Storage Separation: Stateless broker nodes enable second-level elastic scaling and Serverless deployment
- 🔌 Multi-Protocol Unified: Native support for MQTT 3.1/3.1.1/5.0, Kafka, and AMQP with protocol isolation
- 💾 Intelligent Storage Tiering: Memory/SSD/Object storage with Topic-level engine selection for cost optimization
- ☁️ Cloud-Native Ready: Kubernetes-native with auto-scaling, service discovery, and container-friendly deployment
- 🛠️ Zero-Operations: Single binary deployment with built-in Raft consensus and comprehensive management tools
- 🔐 Enterprise Security: Multi-auth support, fine-grained permissions, and end-to-end encryption
- 📊 Full Observability: Prometheus metrics, OpenTelemetry tracing, and Grafana dashboards
- Broker Server: Stateless protocol processing layer supporting MQTT, Kafka, and AMQP with million-level concurrent connections
- Meta Service: Raft-based distributed metadata management and cluster coordination with automatic failover
- Journal Server: High-performance persistent storage engine with WAL guarantees and pluggable storage backends
- Storage Adapter: Unified storage abstraction layer supporting memory, SSD, and object storage with intelligent tiering
- One Binary Deployment: Single executable with zero external dependencies for simplified operations
- Protocol Isolation: Dedicated ports per protocol (MQTT: 1883/1884/8083/8084, Kafka: 9092, AMQP: 5672, gRPC: 1228)
- Compute-Storage Separation: Stateless brokers enable independent scaling and Serverless deployment without data migration
- Topic-Level Storage: Flexible storage engine selection supporting memory, local, and cloud storage backends
# Install and start RobustMQ
curl -fsSL https://raw.githubusercontent.com/robustmq/robustmq/main/scripts/install.sh | bash
broker-server start# Test MQTT connection
mqttx pub -h localhost -p 1883 -t "test/topic" -m "Hello RobustMQ!"
mqttx sub -h localhost -p 1883 -t "test/topic"Access http://localhost:8080 for cluster monitoring and management.
- MQTT Server:
117.72.92.117:1883(admin/robustmq) - Web Dashboard: http://demo.robustmq.com
📚 For detailed installation and usage guides, see our Documentation
# Clone and build
git clone https://github.com/robustmq/robustmq.git
cd robustmq
cargo run --package cmd --bin broker-server
# Build packages
make build # Basic build
make build-full # With frontend📚 For detailed build options, see our Build Guide
- 📖 Official Documentation - Comprehensive guides and API references
- 🚀 Quick Start Guide - Get up and running in minutes
- 🔧 MQTT Documentation - MQTT-specific features and configuration
- 💻 Command Reference - CLI commands and usage
- 🎛️ Web Console - Management interface
We welcome contributions! Check out our Contribution Guide and Good First Issues.
- 🎮 Discord - Real-time chat and collaboration
- 🐛 GitHub Issues - Bug reports and feature requests
- 💡 GitHub Discussions - General discussions
-
微信群: Join our WeChat group for Chinese-speaking users
-
微信公众号: If the group QR code has expired, welcome to follow our official WeChat account!
RobustMQ is licensed under the Apache License 2.0, which strikes a balance between open collaboration and allowing you to use the software in your projects, whether open source or proprietary.