A unified messaging engine built in Rust that supports MQTT, Kafka, NATS, AMQP, and mq9 protocols on a single shared storage layer.
RobustMQ is a unified messaging engine built with Rust that supports multiple protocols—MQTT, Kafka, NATS, AMQP, and mq9—on a single shared storage layer. It solves the problem of fragmented communication infrastructure by allowing messages written once to be consumed by any protocol, enabling seamless data flow from IoT devices to cloud analytics.
Developers and architects building IoT systems, streaming data pipelines, enterprise messaging, or AI agent communication who need a unified, multi-protocol messaging solution.
Developers choose RobustMQ for its ability to replace multiple specialized brokers with one system, its efficient Rust-based implementation with predictable performance, and its unique mq9 protocol designed for asynchronous AI agent communication.
Communication infrastructure for the AI era — one binary, one broker, one storage layer, any protocol
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.
All protocols share a single storage layer, so a message written once can be consumed by any protocol, eliminating data duplication as shown in the architecture diagram.
Built with Rust for no garbage collection and stable memory footprint, ensuring predictable performance from edge to cloud, as highlighted in the features.
Single binary with zero dependencies enables seamless deployment on edge gateways and cloud clusters, with offline buffering and auto-sync capabilities.
Includes the mq9 protocol for asynchronous AI agent messaging with priority queuing and public mailboxes, requiring no new SDKs as it works with any NATS client.
Built-in Raft consensus and a web management console reduce setup complexity, making it ready out-of-the-box as described.
Explicitly stated as not production-ready, with only MQTT stable; Kafka, NATS, AMQP, and mq9 are under active development, targeting production for version 0.4.0.
Most protocols beyond MQTT lack full feature sets and stability, which could lead to bugs or missing functionalities in production use.
As a new project, it lacks the extensive third-party integrations, community plugins, and documentation depth of established brokers like Kafka or RabbitMQ.