# mxsm/rocketmq-rust

🚀Apache RocketMQ build in  Rust🦀. Faster, safer, and with lower memory usage. ⭐ Star to support our work❤️!

Repository: https://github.com/mxsm/rocketmq-rust
Canonical: https://ross.abutalabs.com/products/rocketmq-rust
Homepage: https://rocketmqrust.com/
Language: Rust
License: Apache-2.0
License Family: permissive
Topics: rocketmq, rust, cloud-native, rocketmq-rust, messaging, rocketmq-rust-client, rocketmq-rust-sdk, tauri, ai-sre, mcp, mcp-server, mcp-tools
Last push: 2026-08-26T19:01:34+00:00

## Health v2 (maintenance only)
Score: 81/100 (v2, computed 2026-09-03T02:20:16.233290+00:00)
- activity 99, release rhythm 64, longevity 71
- inputs: {"age_days": 994, "days_push": 7, "days_rel": 80, "gap_med": 92.0, "n_releases_24m": 7}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 1505, forks 246 (observed 2026-08-28T04:04:54.906460+00:00)

## What it is
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
- artifact type: service
- maturity: active
- function: message-queue, rpc, http-server, sdk
- domain: microservices, backend, cloud-computing, developer-tools
- platform: windows, rust, cross-platform
- tags: rocketmq, messaging-middleware, message-broker, producer-consumer, commitlog, nameserver, async-tokio, unofficial-implementation, messaging, linux, macos, docker

## Member repositories
- mxsm/rocketmq-rust (main) score 81

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:04:54.906460+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-30T04:32:42.778295+00:00, confidence not recorded.
  - readme: https://github.com/mxsm/rocketmq-rust (fetched 2026-08-28T04:04:54.906460+00:00, sha e4f503c086ce)
  - homepage: https://rocketmqrust.com/ (fetched 2026-08-29T11:37:18.073039+00:00, sha e36945eea12b)
  - site_page: https://rocketmqrust.com/docs/introduction (fetched 2026-08-29T11:37:18.081913+00:00, sha d95bdc171fab)
  - site_page: https://rocketmqrust.com/docs/architecture/overview (fetched 2026-08-29T11:37:18.083746+00:00, sha 17d59f2a3127)
  - site_page: https://rocketmqrust.com/docs/getting-started/installation (fetched 2026-08-29T11:37:18.085730+00:00, sha f4aa55c0b8ca)
  - site_page: https://rocketmqrust.com/docs/contributing/overview (fetched 2026-08-29T11:37:18.087420+00:00, sha b3cd3e828a22)
  - registry_crates: https://crates.io/api/v1/crates/rocketmq-rust (fetched 2026-08-29T11:37:18.089219+00:00, sha 2c44e82a5cd3)
- Data as of 2026-08-30T08:39:29.467469+00:00.