所有项目
进行中

rocketmq-admin-go

Go 版 RocketMQ 运维管理客户端 —— 补齐官方客户端缺失的 MQAdminExt 能力,可与之共享配置。

GoRocketMQ

官方的 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 许可。具体版本要求与用法见仓库文档。