weihubeats/rocketmq-mcp

3.2

If you are the rightful owner of rocketmq-mcp and would like to certify it and/or have it hosted online, please leave a comment on the right or send an email to henry@mcphub.com.

Apache RocketMQ MCP Server is a model context protocol server designed to facilitate communication and management of RocketMQ clusters using natural language processing.

Tools

1

Resources

0

Prompts

0

rocketmq-mcp

Apache RocketMQ MCP Server

use

配置集群
修改application.yaml文件，添加RocketMQ集群配置

rocketmq:
  clusters:
    - id: 1
      name: xiaoZou
      namesrv-addr: 127.0.0.1:9876

运行
验证mcp server是否启动成功

安装 inspector

npx @modelcontextprotocol/inspector node build/index.js

打开浏览器访问 http://127.0.0.1:6274/

配置 mcp server

{
  "mcpServers": {
    "rocketmq-mcp": {
      "url": "http://localhost:8081/sse",
      "disabled": false,
      "autoApprove": []
    }
  }
}

使用自然语言查询消息

查询集群为xiaozou，topic为xiao-zou-topic，消息id为AC1400010D3E068DE14531D104E40176的消息

使用自然语言发送消息

发送消息到集群为`xiaozou`,topic为`xiao-zou-topic`,消息内容为wh-test-send