RocketMQ

RocketMQ is an MCP server that provides Model Context Protocol interfaces for Apache RocketMQ clusters. Built on Spring Boot, it exposes management endpoints over HTTP, allowing AI assistants and developers to administer distributed messaging infrastructure. Engineers, operations teams, and backend developers use it to inspect and control topics, broker runtimes, and message flows directly through automated workflows. The server enables querying cluster topologies, checking NameServer address lists, and viewing individual messages within queues. It also permits monitoring active consumer connections, verifying producer metadata, examining consume queue states, and updating controller configurations. By bridging LLM environments with administrative APIs, RocketMQ simplifies operational diagnostics, stream debugging, and real-time pub-sub maintenance across complex distributed messaging topologies.

Category: Communication & Messaging

Tags: distributed-systems, messaging, pubsub, rocketmq, streaming

Visit RocketMQ

How to install and configure RocketMQ

1. Clone the repository and navigate to the project directory. 2. Build the project using the build script: bash ./build.sh 3. Run the compiled JAR file: bash java -jar target/rocketmq-mcp-*.jar The server starts on port 6868 by default. 4. To debug locally with MCP tools, run: bash sh mcp_inspector.sh 5. For instructions on connecting your specific MCP client via HTTP, consult the official repository at https://github.com/francisoliverlee/rocketmq-mcp.

What you can do with RocketMQ

• Querying RocketMQ broker runtime statistics to diagnose node-level performance bottlenecks and latency issues. - Inspecting consumer connection details and consume queue statuses to identify lagging message processors. - Fetching NameServer address lists and cluster topology data to monitor cluster availability across environments. - Viewing specific messages across topics to verify payload delivery and trace distributed event logs. - Updating and inspecting controller configurations dynamically without switching out of developer diagnostic tooling.

Key facts

• Open Source
• https://github.com/francisoliverlee/rocketmq-mcp
• Communication & Messaging, Data & Analytics
• distributed-systems, messaging, pubsub, rocketmq, streaming

Part of MCP Servers

What is the RocketMQ MCP server?

RocketMQ MCP server is a Spring Boot application that exposes Apache RocketMQ management functions over HTTP. It allows AI assistants and developer tools to interact with topics, brokers, consumers, and message queues.

How do I run the RocketMQ MCP server?

You build the project with the build.sh script, then start the JAR using java -jar target/rocketmq-mcp-*.jar. The server runs on port 6868 according to default configuration settings.

What RocketMQ components can the server manage?

The server provides interfaces for Controllers, NameServers, Messages, Brokers, ACL rules, Consumers, Topics, Clusters, Producers, and ConsumeQueues. These endpoints allow comprehensive administration and monitoring of your messaging infrastructure.

Is the RocketMQ MCP server open source?

Yes, RocketMQ MCP server is open source. The complete source code and testing tools are accessible in the GitHub repository at https://github.com/francisoliverlee/rocketmq-mcp.