进行中
rocketmq-admin-go
Go 版 RocketMQ 运维管理客户端 —— 补齐官方客户端缺失的 MQAdminExt 能力,可与之共享配置。
GoRocketMQ
1
Go
2026-09 更新
官方的 rocketmq-client-go
专注消息的生产与消费,运维管理这块一直没有原生支持——Java 那边有 MQAdminExt,Go 这边想查个消费进度、重置个位点,就只能自己拼协议。
这个库把 MQAdminExt 的能力补到 Go 上,作为官方客户端的增强包使用,配置可以两边共享,写一次即可。
能力范围#
| 模块 | 内容 |
|---|---|
| 配置共享 | 与 rocketmq-client-go 无缝集成,配置一次两边通用 |
| 基础运维 | 集群状态监控、Broker 运行时信息、NameServer 配置管理 |
| Topic 管理 | 创建与删除、路由查询、静态 Topic、权限控制 |
| 消费者管理 | 订阅组、消费进度、在线客户端查询、重置消费位点 |
| 消息操作 | 轨迹查询、直接消费、死信队列处理、半消息恢复 |
| 权限安全 | 5.x RBAC ACL 与 4.x 旧版 ACL,白名单/黑名单规则 |
| 高级功能 | KV 配置、Controller 模式(5.x)、冷数据流控、RocksDB 调优 |
go get github.com/amigoer/rocketmq-admin-go@latest支持 RocketMQ 4.x / 5.x,Apache-2.0 许可。具体版本要求与用法见仓库文档。