io.github.LarsCowe/queue-pilot

Official

Queue Pilot

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

Message queue inspector for RabbitMQ and Kafka with JSON Schema validation.

Install

Configuration

Environment variables

RABBITMQ_URLdefault http://localhost:15672

RabbitMQ Management API URL

RABBITMQ_USERsecret

RabbitMQ username

RABBITMQ_PASSsecret

RabbitMQ password

KAFKA_BROKERSdefault localhost:9092

Comma-separated Kafka broker addresses

KAFKA_CLIENT_IDdefault queue-pilot

Kafka client ID

KAFKA_SASL_MECHANISM

SASL mechanism: plain, scram-sha-256, scram-sha-512

KAFKA_SASL_USERNAMEsecret

SASL username

KAFKA_SASL_PASSWORDsecret

SASL password

Arguments

--schemasrequired

filepath

--broker

string

claude_desktop_config.json

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot@0.5.1",
        "--schemas",
        "<YOUR__SCHEMAS>",
        "--broker"
      ],
      "env": {
        "RABBITMQ_URL": "http://localhost:15672",
        "RABBITMQ_USER": "guest",
        "RABBITMQ_PASS": "guest",
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "queue-pilot",
        "KAFKA_SASL_MECHANISM": "<YOUR_KAFKA_SASL_MECHANISM>",
        "KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
        "KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>"
      }
    }
  }
}