MCP Server

Queue Pilot MCP Server

Name: Queue Pilot MCP Server
Author: io.github.LarsCowe

io.github.LarsCowe/queue-pilot

Repository Registry

What is the Queue Pilot MCP server?

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

How to install Queue Pilot

Copy-paste configuration for popular MCP clients.

transport: stdio

Config generated by PluginBench — verify against the source before use.

Environment / auth

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

Claude Desktop

~/Library/Application Support/Claude/claude_desktop_config.json

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "<YOUR_RABBITMQ_URL>",
        "RABBITMQ_USER": "<YOUR_RABBITMQ_USER>",
        "RABBITMQ_PASS": "<YOUR_RABBITMQ_PASS>",
        "KAFKA_BROKERS": "<YOUR_KAFKA_BROKERS>",
        "KAFKA_CLIENT_ID": "<YOUR_KAFKA_CLIENT_ID>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>"
      }
    }
  }
}

Cursor

~/.cursor/mcp.json

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "<YOUR_RABBITMQ_URL>",
        "RABBITMQ_USER": "<YOUR_RABBITMQ_USER>",
        "RABBITMQ_PASS": "<YOUR_RABBITMQ_PASS>",
        "KAFKA_BROKERS": "<YOUR_KAFKA_BROKERS>",
        "KAFKA_CLIENT_ID": "<YOUR_KAFKA_CLIENT_ID>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>"
      }
    }
  }
}

Windsurf

~/.codeium/windsurf/mcp_config.json

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "<YOUR_RABBITMQ_URL>",
        "RABBITMQ_USER": "<YOUR_RABBITMQ_USER>",
        "RABBITMQ_PASS": "<YOUR_RABBITMQ_PASS>",
        "KAFKA_BROKERS": "<YOUR_KAFKA_BROKERS>",
        "KAFKA_CLIENT_ID": "<YOUR_KAFKA_CLIENT_ID>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>"
      }
    }
  }
}

VS Code

.vscode/mcp.json

{
  "servers": {
    "queue-pilot": {
      "type": "stdio",
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot",
        "--schemas",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "<YOUR_RABBITMQ_URL>",
        "RABBITMQ_USER": "<YOUR_RABBITMQ_USER>",
        "RABBITMQ_PASS": "<YOUR_RABBITMQ_PASS>",
        "KAFKA_BROKERS": "<YOUR_KAFKA_BROKERS>",
        "KAFKA_CLIENT_ID": "<YOUR_KAFKA_CLIENT_ID>",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>"
      }
    }
  }
}

Claude Code

claude mcp add queue-pilot --env RABBITMQ_URL=<YOUR_RABBITMQ_URL> --env RABBITMQ_USER=<YOUR_RABBITMQ_USER> --env RABBITMQ_PASS=<YOUR_RABBITMQ_PASS> --env KAFKA_BROKERS=<YOUR_KAFKA_BROKERS> --env KAFKA_CLIENT_ID=<YOUR_KAFKA_CLIENT_ID> --env KAFKA_SASL_MECHANISM=<YOUR_KAFKA_SASL_MECHANISM> --env KAFKA_SASL_USERNAME=<YOUR_KAFKA_SASL_USERNAME> --env KAFKA_SASL_PASSWORD=<YOUR_KAFKA_SASL_PASSWORD> -- npx -y queue-pilot --schemas --broker