rocketbroker/rocketmq repository overview

RocketMQ is a high-performance AMQP 0-9-1 message broker written in Rust and designed as a drop-in replacement for RabbitMQ.

It provides native Protobuf schema validation directly in the broker, enabling type-safe messaging without requiring an external schema registry. Messages are validated against consumer-defined contracts before delivery, preventing invalid payloads from reaching applications.

Features include RabbitMQ wire compatibility, durable queues, exchanges, TLS, Raft-based clustering, WAL persistence, and OpenTelemetry metrics.