MCP.so
登录

Rocketmq MCP Server

@francisoliverlee

基本信息

分类

其他

许可证

Apache-2.0

传输方式

stdio

作者

francisoliverlee

提交者

tiger lee

关于 Rocketmq MCP Server

RocketMQ Mcp Server

Rocketmq MCP Server 配置

使用下面的配置,将此服务器添加到你的 MCP 客户端。

{
  "mcpServers": {
    "rocketmq-mcp": {
      "command": "java",
      "args": [
        "-jar",
        "rocketmq-mcp-server.jar"
      ],
      "env": {
        "NS_ADDR": "<Your-Namesrv-Address-List>",
        "AK": "<Access-Key-Of-Admin>",
        "SK": "<Secret-Key-Of-Admin>"
      }
    }
  }
}

Rocketmq MCP Server 工具

工具列表暂未提供

当前收录暂时没有可展示的工具列表,不代表服务没有工具。请查阅项目文档了解支持的能力。

工具是从 README 中自动提取的。维护者可以在 ## Tools 标题下列出工具,即可填充这部分内容。

概览

What is Rocketmq Mcp?

Rocketmq Mcp is a Spring Boot‑based server that provides HTTP interfaces for managing Apache RocketMQ. It exposes endpoints for common RocketMQ administrative tasks such as querying topics, brokers, consumers, and clusters. It is intended for developers and operators who need a programmatic way to interact with a RocketMQ cluster.

How to use Rocketmq Mcp?

Build the project with ./build.sh, then run the server with java -jar target/rocketmq-mcp-*.jar. The server listens on port 6868 by default. All available HTTP API endpoints are documented in the README and can be called with POST requests. Python test scripts in the test/ directory can be used to verify functionality.

Key features of Rocketmq Mcp

  • Provides RESTful HTTP APIs for RocketMQ management
  • Covers Controller, Nameserver, Broker, Topic, and Consumer operations
  • Includes Python test scripts (unittest and demonstration)
  • Easily extensible with new tool classes
  • Configuration via standard Spring Boot application.properties
  • Supports local debugging with the MCP inspector tool

Use cases of Rocketmq Mcp

  • Automating RocketMQ cluster administration tasks
  • Integrating RocketMQ operations into CI/CD pipelines
  • Building custom monitoring or management dashboards
  • Testing RocketMQ API behavior during development
  • Enabling AI agents to interact with RocketMQ via MCP protocol

常见问题

1

What dependencies are required to run Rocketmq Mcp?

Java (Maven‑managed dependencies from `pom.xml`) and a running RocketMQ cluster. For the test suite, Python 3 with packages from `test/requirements.txt` is needed.

2

How can I add a new management endpoint to Rocketmq Mcp?

Create a new tool class in `src/main/java/org/apache/rocketmq/mcp/tool/`, implement the HTTP interface, register it in `ToolsLoader.java`, and add corresponding test cases in the `test/` directory.

3

What transport does Rocketmq Mcp use?

All communication is over HTTP. The server listens on port 6868 and expects POST requests to the documented endpoints.

4

Where can I find the server configuration file?

Configuration is located at `src/main/resources/application.properties`, where you can change the server port and application name.

5

Does Rocketmq Mcp support authentication or ACL?

The server exposes ACL endpoints such as `POST /acl/getAclVersionList`, but authentication itself is not described in the README.

评论

其他 分类下的更多 MCP 服务器