MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation
npx -y queue-pilot{
"RABBITMQ_URL": "http://localhost:15672",
"RABBITMQ_USER": "guest",
"RABBITMQ_PASS": "guest",
"KAFKA_BROKERS": "localhost:9092",
"KAFKA_CLIENT_ID": "queue-pilot",
"KAFKA_SASL_MECHANISM": "YOUR_VALUE_HERE",
"KAFKA_SASL_USERNAME": "YOUR_SECRET_VALUE",
"KAFKA_SASL_PASSWORD": "YOUR_SECRET_VALUE"
}Add this server entry to the mcpServers object in your Claude Desktop config, then restart the app.
{
"mcpServers": {
"io-github-larscowe-queue-pilot": {
"command": "npx",
"args": [
"-y",
"queue-pilot"
],
"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_VALUE_HERE",
"KAFKA_SASL_USERNAME": "YOUR_SECRET_VALUE",
"KAFKA_SASL_PASSWORD": "YOUR_SECRET_VALUE"
}
}
}
}~/Library/Application Support/Claude/claude_desktop_config.json%APPDATA%\Claude\claude_desktop_config.jsonNo remote HTTP endpoint is advertised. Use the package or stdio setup shown in Install.
Queue Pilot is an MCP server for MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation. It supports STDIO transport.
Use the generated config in Install. This server runs with npx -y queue-pilot; add any required environment variables before starting your client.
Choose the Claude Desktop tab in Install and copy the config for npx -y queue-pilot. Add required environment variables before starting Claude Desktop.
Choose the Claude Code tab in Install and copy the config for npx -y queue-pilot. Add required environment variables before starting Claude Code.
Choose the Codex tab in Install and copy the config for npx -y queue-pilot. Add required environment variables before starting Codex.
Choose the Cursor or VS Code tab in Install and copy the config for npx -y queue-pilot. Add required environment variables before starting Cursor or VS Code.
Queue Pilot uses STDIO transport. Use the package or command config in Install.
Queue Pilot inventory is listed when the MCP endpoint exposes tools, resources, or prompts. Some servers require auth first.
Queue Pilot is marked with Auth required by registry metadata auth. You may need provider login, an API key, a bearer token, or a session header.
| Package | Registry | Version | Inputs |
|---|---|---|---|
queue-pilotstdio | npm | 0.5.1 | Argument: --schemas Argument: --broker Env: RABBITMQ_URL Env: RABBITMQ_USER secret Env: RABBITMQ_PASS secret Env: KAFKA_BROKERS Env: KAFKA_CLIENT_ID Env: KAFKA_SASL_MECHANISM Env: KAFKA_SASL_USERNAME secret Env: KAFKA_SASL_PASSWORD secret |