Queue Pilot

Indexed by io.github.LarsCowe

About

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

Use this server

Add it to your MCP client. The catalogue lists this config verbatim from its source — it does not run, download, or vouch for the server. Review the command before you run it.

Transportstdio (runs a local command)

Env varsRABBITMQ_URL RABBITMQ_USER RABBITMQ_PASS KAFKA_BROKERS KAFKA_CLIENT_ID KAFKA_SASL_MECHANISM KAFKA_SASL_USERNAME KAFKA_SASL_PASSWORD

Claude Code

claude mcp add --env RABBITMQ_URL= --env RABBITMQ_USER= --env RABBITMQ_PASS= --env KAFKA_BROKERS= --env KAFKA_CLIENT_ID= --env KAFKA_SASL_MECHANISM= --env KAFKA_SASL_USERNAME= --env KAFKA_SASL_PASSWORD= queue-pilot -- npx queue-pilot

Cursor

Add to Cursor

If the button doesn't open Cursor, use the JSON below — Cursor accepts the same mcpServers config.

VS Code

code --add-mcp '{"name":"queue-pilot","command":"npx","args":["queue-pilot"],"env":{"RABBITMQ_URL":"","RABBITMQ_USER":"","RABBITMQ_PASS":"","KAFKA_BROKERS":"","KAFKA_CLIENT_ID":"","KAFKA_SASL_MECHANISM":"","KAFKA_SASL_USERNAME":"","KAFKA_SASL_PASSWORD":""}}'

JSON

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "queue-pilot"
      ],
      "env": {
        "RABBITMQ_URL": "",
        "RABBITMQ_USER": "",
        "RABBITMQ_PASS": "",
        "KAFKA_BROKERS": "",
        "KAFKA_CLIENT_ID": "",
        "KAFKA_SASL_MECHANISM": "",
        "KAFKA_SASL_USERNAME": "",
        "KAFKA_SASL_PASSWORD": ""
      }
    }
  }
}

Environment variables are listed by name only — fill in your own values. Entries never carry secrets.