Introduction & Vision • Features • Roadmap • Architecture • Quick Start • Documentation • Contributing • Community
⚠️ Development Status RobustMQ is in early development and not production-ready. We are currently in Phase 1 focusing on building a solid architectural foundation. See Roadmap for detailed development plan and timeline.
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.
RobustMQ is exploring to become an ALL-IN-ONE next-generation messaging platform. Our core philosophy: Simplicity and Slow is Fast.
This is a long-term journey. We prioritize building a rock-solid foundation over rushing features. We believe in avoiding the chaos of frequent refactoring by investing time upfront in thoughtful design and architecture.
As a community-driven project (not a commercial venture), we embrace being slow and deliberate. We're committed to quality over speed, depth over breadth. The journey is as important as the destination — and we're here for the long run.
Target: Become the next-generation cloud-native and AI-native messaging infrastructure, aspiring to Apache top-level project status.
Long-term Vision: Minimalist architecture with multi-protocol support, pluggable storage, and minimal deployment footprint.
Phase 1: Foundation (Current) - Building a scalable technical architecture with solid, streamlined, and abstraction-friendly code implementation. Establishing a robust foundation for multi-protocol adaptation, pluggable storage, extensibility, and elasticity. We are investing significant time here to avoid frequent refactoring in the long term.
Phase 2: MQTT Broker - Deliver a stable, high-performance MQTT Broker with complete protocol support (MQTT 3.x/5.0/SN) and optimized for edge deployment with package size under 20MB.
Phase 3: Kafka Protocol - Start Kafka protocol adaptation work after achieving Phase 1 and 2 goals.
- 🚀 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/1885/8083/8085, 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.