Rocketmq Mcp

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.

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.

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.

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.