Queue Pilot

io.github.LarsCowe/queue-pilot·v0.5.1·Other

Quality Score

/100

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

Repository →Website →

§01 Install

Claude Desktop (claude_desktop_config.json)

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot"
      ],
      "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>"
      }
    }
  }
}

Cursor (.cursor/mcp.json)

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot"
      ],
      "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>"
      }
    }
  }
}

Cline (cline_mcp_settings.json)

npx -y queue-pilot

§02 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

§03 MCP Quality Score · methodology

freshness

completeness

installability

documentation

stability

§04 Alternatives in Other

agency.lona/trading

AI-powered trading strategy development: backtesting, market data, and portfolio analysis

ABMeter

ai.abmeter/abmeter

Feature flagging and A/B testing platform with AI-first experimentation workflows.

AdAdvisor MCP Server

ai.adadvisor/mcp-server

Query Meta Ads performance data — accounts, campaigns, ad sets, ads, metrics & settings.