Rocketmq Mcp

Name: Rocketmq Mcp
Author: francisoliverlee

@francisoliverlee

Repository

About Rocketmq Mcp

RocketMQ Mcp Server

Basic information

Config

Add this server to your MCP-compatible client using the configuration below.

{
  "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>"
      }
    }
  }
}

Tools

No tools detected

We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.

Overview

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

FAQ from Rocketmq Mcp

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.

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.