MCP Server
MCP
Queue Pilot
MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation
Install
npx -y [email protected]
Configuration Example
{
"remotes": [],
"packages": [
{
"registryType": "npm",
"registryBaseUrl": "https://registry.npmjs.org",
"identifier": "queue-pilot",
"version": "0.5.1",
"runtimeHint": "npx",
"transport": {
"type": "stdio"
},
"packageArguments": [
{
"description": "Path to directory containing JSON Schema files",
"isRequired": true,
"type": "named",
"name": "--schemas",
"valueHint": "filepath"
},
{
"description": "Broker type: rabbitmq or kafka (default: rabbitmq)",
"type": "named",
"name": "--broker",
"valueHint": "string"
}
],
"environmentVariables": [
{
"description": "RabbitMQ Management API URL",
"format": "string",
"default": "http://localhost:15672",
"name": "RABBITMQ_URL"
},
{
"description": "RabbitMQ username",
"format": "string",
"isSecret": true,
"default": "guest",
"name": "RABBITMQ_USER"
},
{
"description": "RabbitMQ password",
"format": "string",
"isSecret": true,
"default": "guest",
"name": "RABBITMQ_PASS"
},
{
"description": "Comma-separated Kafka broker addresses",
"format": "string",
"default": "localhost:9092",
"name": "KAFKA_BROKERS"
},
{
"description": "Kafka client ID",
"format": "string",
"default": "queue-pilot",
"name": "KAFKA_CLIENT_ID"
},
{
"description": "SASL mechanism: plain, scram-sha-256, scram-sha-512",
"format": "string",
"name": "KAFKA_SASL_MECHANISM"
},
{
"description": "SASL username",
"format": "string",
"isSecret": true,
"name": "KAFKA_SASL_USERNAME"
},
{
"description": "SASL password",
"format": "string",
"isSecret": true,
"name": "KAFKA_SASL_PASSWORD"
}
]
}
]
}
mcp
model-context-protocol
npm
By
Comments
Sign in to leave a comment