The Rust Implementation of Apache RocketMQ Broker

Overview

This module is mainly the implementation of the Apache RocketMQ Broker, containing all the functionalities of the Java version Broker.

Getting Started

Requirements

1. rust toolchain MSRV is 1.75.(stable,nightly)

Run Borker

Run the following command to see usage：

• windows platform

  cargo run --bin rocketmq-broker-rust -- --help
  
  RocketMQ Broker Server(Rust)
  
  Usage: rocketmq-broker-rust.exe [OPTIONS]
  
  Options:
    -c, --config-file <FILE>      Broker config properties file
    -m, --print-important-config  Print important config item
    -n, --namesrv-addr <IP>       Name server address list, eg: '192.168.0.1:9876;192.168.0.2:9876' [default: 127.0.0.1:9876]
    -p, --print-config-item       Print all config item
    -h, --help                    Print help
    -V, --version                 Print version
  

• Linux platform

  $ cargo run --bin rocketmq-broker-rust -- --help
  
  RocketMQ Broker Server(Rust)
  
  Usage: rocketmq-broker-rust [OPTIONS]
  
  Options:
    -c, --config-file <FILE>      Broker config properties file
    -m, --print-important-config  Print important config item
    -n, --namesrv-addr <IP>       Name server address list, eg: '192.168.0.1:9876;192.168.0.2:9876' [default: 127.0.0.1:9876]
    -p, --print-config-item       Print all config item
    -h, --help                    Print help
    -V, --version                 Print version
  

Run the following command to start the name server

cargo run --bin rocketmq-broker-rust

Feature

Feature list:

• Not support: 💔 ❌
• Base support: ❤️ ✅
• Perfect support: 💖 ✅