进行中

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 调优
bash
go get github.com/amigoer/rocketmq-admin-go@latest

支持 RocketMQ 4.x / 5.x,Apache-2.0 许可。具体版本要求与用法见仓库文档。

评论