Queue Pilot
MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation
Installation
Ajoutez ceci à la configuration MCP de votre client (Claude Desktop : claude_desktop_config.json ; Cursor : .cursor/mcp.json ; VS Code et les autres utilisent la même forme « mcpServers »).
queue-pilotclaude mcp add queue-pilot -e 'RABBITMQ_URL=http://localhost:15672' -e 'RABBITMQ_USER=<your rabbitmq_user>' -e 'RABBITMQ_PASS=<your rabbitmq_pass>' -e 'KAFKA_BROKERS=localhost:9092' -e 'KAFKA_CLIENT_ID=queue-pilot' -e 'KAFKA_SASL_MECHANISM=<KAFKA_SASL_MECHANISM>' -e 'KAFKA_SASL_USERNAME=<your kafka_sasl_username>' -e 'KAFKA_SASL_PASSWORD=<your kafka_sasl_password>' -- npx -y queue-pilot@0.5.1 --schemas '<filepath>' --broker '<string>'
{
"mcpServers": {
"queue-pilot": {
"command": "npx",
"args": [
"-y",
"queue-pilot@0.5.1",
"--schemas",
"<filepath>",
"--broker",
"<string>"
],
"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>"
}
}
}
}
Variables d'environnement
RABBITMQ_URLRabbitMQ Management API URLRABBITMQ_USERsecret RabbitMQ usernameRABBITMQ_PASSsecret RabbitMQ passwordKAFKA_BROKERSComma-separated Kafka broker addressesKAFKA_CLIENT_IDKafka client IDKAFKA_SASL_MECHANISMSASL mechanism: plain, scram-sha-256, scram-sha-512KAFKA_SASL_USERNAMEsecret SASL usernameKAFKA_SASL_PASSWORDsecret SASL password
Questions fréquentes
Qu'est-ce que Queue Pilot ?
MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation
Comment installer Queue Pilot ?
Il s'exécute sur votre machine. Dans Claude Code : claude mcp add queue-pilot -e 'RABBITMQ_URL=http://localhost:15672' -e 'RABBITMQ_USER=<your rabbitmq_user>' -e 'RABBITMQ_PASS=<your rabbitmq_pass>' -e 'KAFKA_BROKERS=localhost:9092' -e 'KAFKA_CLIENT_ID=queue-pilot' -e 'KAFKA_SASL_MECHANISM=<KAFKA_SASL_MECHANISM>' -e 'KAFKA_SASL_USERNAME=<your kafka_sasl_username>' -e 'KAFKA_SASL_PASSWORD=<your kafka_sasl_password>' -- npx -y queue-pilot@0.5.1 --schemas '<filepath>' --broker '<string>'. Pour les autres clients, collez la configuration JSON de cette page dans leurs réglages MCP.
Faut-il une clé API pour Queue Pilot ?
Oui. Il attend RABBITMQ_USER, RABBITMQ_PASS, KAFKA_SASL_USERNAME, KAFKA_SASL_PASSWORD, à renseigner dans sa configuration.
Queue Pilot est-il open source ?
Son code est public sur GitHub, mais le dépôt ne déclare pas de licence standard.
Qui maintient Queue Pilot ?
Il est publié par LarsCowe. AI.tn le référence sans le maintenir ni le recommander.
Issu du registre MCP officiel. Être listé n'est pas une recommandation : vérifiez le code et les permissions d'un serveur avant de lui donner accès à vos données.