mxsm/rocketmq-rust
🚀 Apache RocketMQ built in Rust 🦀 — faster, safer, and more memory-efficient. Powering high-performance messaging for the AI era, with AI Agent, MCP, and AI-SRE capabilities. observed · 2026-10-20
Health v2 · maintenance only
85/100
- Activity 100
- Release rhythm 73
- Longevity 74
How is this computed?
round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10) — computed 2026-10-21. Adoption (stars, forks) is never an input.
- gap_med: 92
- age_days: 1042
- days_rel: 20
- days_push: 1
- n_releases_24m: 8
Adoption not part of the score
1529 stars · 291 forks observed · 2026-10-20
What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded
An unofficial, high-performance Rust implementation of Apache RocketMQ, providing message broker, NameServer, producer, and consumer components built on Tokio async I/O. It aims for RocketMQ 5.x protocol compatibility with lower memory usage and memory safety.
Use cases
- run a RocketMQ-compatible message broker written in Rust
- send and consume messages with a Rust RocketMQ client SDK
- build event-driven microservices with reliable message delivery
- implement transactional messaging in Rust
- self-host a lightweight message queue for high-throughput pipelines
- stream high-volume data between services asynchronously
When to choose
- you want RocketMQ semantics (CommitLog, NameServer, push/pull consumers) in a Rust-native stack
- memory safety and low memory footprint are priorities for your messaging infrastructure
- your services are written in Rust and you want idiomatic async producer/consumer APIs
- you need cross-platform (Linux/macOS/Windows) message middleware
When to avoid
- you need the official, fully battle-tested Apache RocketMQ Java implementation for production-critical workloads
- you require complete RocketMQ 5.x feature parity, since this is an unofficial reimplementation still maturing
- your team primarily works in Java or other JVM ecosystems
- you need Kafka- or RabbitMQ-specific features instead of RocketMQ
Facets
service · maturity active
message-queue rpc http-server sdk microservices backend cloud-computing developer-tools windows rust cross-platform rocketmq messaging-middleware message-broker producer-consumer commitlog nameserver async-tokio unofficial-implementation messaging linux macos docker
7 sources
- readme: https://github.com/mxsm/rocketmq-rust · fetched 2026-10-20 · e4f503c086ce
- homepage: https://rocketmqrust.com/ · fetched 2026-08-29 · e36945eea12b
- site_page: https://rocketmqrust.com/docs/introduction · fetched 2026-08-29 · d95bdc171fab
- site_page: https://rocketmqrust.com/docs/architecture/overview · fetched 2026-08-29 · 17d59f2a3127
- site_page: https://rocketmqrust.com/docs/getting-started/installation · fetched 2026-08-29 · f4aa55c0b8ca
- site_page: https://rocketmqrust.com/docs/contributing/overview · fetched 2026-08-29 · b3cd3e828a22
- registry_crates: https://crates.io/api/v1/crates/rocketmq-rust · fetched 2026-08-29 · 2c44e82a5cd3
Member repositories
| Repository | Role | Health v2 |
|---|---|---|
| mxsm/rocketmq-rust | main | 85 |
For agents
markdown · JSON · MCP: product_card(name="mxsm/rocketmq-rust")
Data as of 2026-10-19T08:05:51.212177+00:00 · Report a problem