English Français العربية

Queue Pilot

Official registry Developer tools

MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation

Source code Website

Install

Add this to your client's MCP configuration (Claude Desktop: claude_desktop_config.json; Cursor: .cursor/mcp.json; VS Code and others use the same "mcpServers" shape).

NPM package queue-pilot
Claude Code 
claude mcp add queue-pilot -e 'RABBITMQ_URL=http://localhost:15672' -e 'RABBITMQ_USER=<your rabbitmq_user>' -e 'RABBITMQ_PASS=<your rabbitmq_pass>' -e 'KAFKA_BROKERS=localhost:9092' -e 'KAFKA_CLIENT_ID=queue-pilot' -e 'KAFKA_SASL_MECHANISM=<KAFKA_SASL_MECHANISM>' -e 'KAFKA_SASL_USERNAME=<your kafka_sasl_username>' -e 'KAFKA_SASL_PASSWORD=<your kafka_sasl_password>' -- npx -y queue-pilot@0.5.1 --schemas '<filepath>' --broker '<string>'
JSON configuration (Claude Desktop, Cursor, VS Code) 
{
    "mcpServers": {
        "queue-pilot": {
            "command": "npx",
            "args": [
                "-y",
                "queue-pilot@0.5.1",
                "--schemas",
                "<filepath>",
                "--broker",
                "<string>"
            ],
            "env": {
                "RABBITMQ_URL": "http://localhost:15672",
                "RABBITMQ_USER": "<your rabbitmq_user>",
                "RABBITMQ_PASS": "<your rabbitmq_pass>",
                "KAFKA_BROKERS": "localhost:9092",
                "KAFKA_CLIENT_ID": "queue-pilot",
                "KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
                "KAFKA_SASL_USERNAME": "<your kafka_sasl_username>",
                "KAFKA_SASL_PASSWORD": "<your kafka_sasl_password>"
            }
        }
    }
}

Environment variables

  • RABBITMQ_URL RabbitMQ Management API URL
  • RABBITMQ_USER secret RabbitMQ username
  • RABBITMQ_PASS secret RabbitMQ password
  • KAFKA_BROKERS Comma-separated Kafka broker addresses
  • KAFKA_CLIENT_ID Kafka client ID
  • KAFKA_SASL_MECHANISM SASL mechanism: plain, scram-sha-256, scram-sha-512
  • KAFKA_SASL_USERNAME secret SASL username
  • KAFKA_SASL_PASSWORD secret SASL password

Frequently asked questions

What is Queue Pilot?

MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation

How do I install Queue Pilot?

It runs on your machine. In Claude Code: claude mcp add queue-pilot -e 'RABBITMQ_URL=http://localhost:15672' -e 'RABBITMQ_USER=<your rabbitmq_user>' -e 'RABBITMQ_PASS=<your rabbitmq_pass>' -e 'KAFKA_BROKERS=localhost:9092' -e 'KAFKA_CLIENT_ID=queue-pilot' -e 'KAFKA_SASL_MECHANISM=<KAFKA_SASL_MECHANISM>' -e 'KAFKA_SASL_USERNAME=<your kafka_sasl_username>' -e 'KAFKA_SASL_PASSWORD=<your kafka_sasl_password>' -- npx -y queue-pilot@0.5.1 --schemas '<filepath>' --broker '<string>'. For other clients, paste the JSON configuration from this page into their MCP settings.

Does Queue Pilot need an API key?

Yes. It expects RABBITMQ_USER, RABBITMQ_PASS, KAFKA_SASL_USERNAME, KAFKA_SASL_PASSWORD, which you set in its configuration.

Is Queue Pilot open source?

Its code is public on GitHub, but the repository does not declare a standard license.

Who maintains Queue Pilot?

It is published by LarsCowe. AI.tn lists it but does not maintain or endorse it.

From the official MCP Registry. Listing is not an endorsement: review a server's code and permissions before giving it access to your data.