#rocket-mq #nameserver #namespaces #rust

nightly bin+lib rocketmq-namesrv

Rust implementation of Apache rocketmq name sever

3 releases (breaking)

new 0.3.0 Nov 17, 2024
0.2.0 Jun 4, 2024
0.1.0 Jan 28, 2024

#140 in HTTP server

Download history 14/week @ 2024-09-23 19/week @ 2024-09-30 51/week @ 2024-11-11

51 downloads per month

MIT/Apache

1.5MB
27K SLoC

The Rust Implementation of Apache RocketMQ Name server

Overview

Here is the rust implementation of the name server for Apache RocketMQ.

Feature

Feature list:

  • Not support: 💔 ❌

  • Base support: ❤️ ✅

  • Perfect support: 💖 ✅

Feature request code Support remark
Put KV Config 100 💖 ✅
Get KV Config 101 💖 ✅
Delete KV Config 102 💖 ✅
Get kv list by namespace 219 💖 ✅
Query Data Version 322 💖 ✅
Register Broker 103 💖 ✅
Unregister Broker 104 💖 ✅
Broker Heartbeat 904 💖 ✅
Get broker member_group 901 💖 ✅
Get broker cluster info 106 💖 ✅
Wipe write perm of boker 205 💖 ✅
Add write perm of brober 327 💖 ✅
Get all topic list from name server 206 💖 ✅
Delete topic in name server 216 💖 ✅
Register topic in name server 217 💖 ✅
Get topics by cluster 224 💖 ✅
Get system topic list from name server 304 💖 ✅
Get unit topic list 311 💖 ✅
Get has unit sub topic list 312 💖 ✅
Get has unit sub ununit topic list 313 💖 ✅
Update name server config 318 💔 ❌
Get name server config 319 💔 ❌

Getting Started

Requirements

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

Run name server

Run the following command to see usage:

  • windows platform

    cargo run --bin rocketmq-namesrv-rust -- --help
    
    RocketMQ Name server(Rust)
    
    Usage: rocketmq-namesrv-rust.exe [OPTIONS]
    
    Options:
      -p, --port <PORT>  rocketmq name server port [default: 9876]
      -i, --ip <IP>      rocketmq name server ip [default: 127.0.0.1]
      -h, --help         Print help
      -V, --version      Print version
    
  • Linux platform

    $ cargo run --bin rocketmq-namesrv-rust -- --help
    
    RocketMQ Name remoting_server(Rust)
    
    Usage: rocketmq-namesrv-rust [OPTIONS]
    
    Options:
      -p, --port <PORT>  rocketmq name remoting_server port [default: 9876]
      -i, --ip <IP>      rocketmq name remoting_server ip [default: 127.0.0.1]
      -h, --help         Print help
      -V, --version      Print version
    

Run the following command to start the name server

cargo run --bin rocketmq-namesrv-rust

Dependencies

~22–55MB
~893K SLoC