MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation
Connect Runs on your machine
claude mcp add queue-pilot -e RABBITMQ_URL=<RABBITMQ_URL> -e RABBITMQ_USER=<RABBITMQ_USER> -e RABBITMQ_PASS=<RABBITMQ_PASS> -e KAFKA_BROKERS=<KAFKA_BROKERS> -e KAFKA_CLIENT_ID=<KAFKA_CLIENT_ID> -e KAFKA_SASL_MECHANISM=<KAFKA_SASL_MECHANISM> -e KAFKA_SASL_USERNAME=<KAFKA_SASL_USERNAME> -e KAFKA_SASL_PASSWORD=<KAFKA_SASL_PASSWORD> -- npx -y [email protected]{
"mcpServers": {
"queue-pilot": {
"command": "npx",
"args": [
"-y",
"[email protected]"
],
"env": {
"RABBITMQ_URL": "<RABBITMQ_URL>",
"RABBITMQ_USER": "<RABBITMQ_USER>",
"RABBITMQ_PASS": "<RABBITMQ_PASS>",
"KAFKA_BROKERS": "<KAFKA_BROKERS>",
"KAFKA_CLIENT_ID": "<KAFKA_CLIENT_ID>",
"KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
"KAFKA_SASL_USERNAME": "<KAFKA_SASL_USERNAME>",
"KAFKA_SASL_PASSWORD": "<KAFKA_SASL_PASSWORD>"
}
}
}
}{
"mcpServers": {
"queue-pilot": {
"command": "npx",
"args": [
"-y",
"[email protected]"
],
"env": {
"RABBITMQ_URL": "<RABBITMQ_URL>",
"RABBITMQ_USER": "<RABBITMQ_USER>",
"RABBITMQ_PASS": "<RABBITMQ_PASS>",
"KAFKA_BROKERS": "<KAFKA_BROKERS>",
"KAFKA_CLIENT_ID": "<KAFKA_CLIENT_ID>",
"KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
"KAFKA_SASL_USERNAME": "<KAFKA_SASL_USERNAME>",
"KAFKA_SASL_PASSWORD": "<KAFKA_SASL_PASSWORD>"
}
}
}
}{
"servers": {
"queue-pilot": {
"type": "stdio",
"command": "npx",
"args": [
"-y",
"[email protected]"
],
"env": {
"RABBITMQ_URL": "<RABBITMQ_URL>",
"RABBITMQ_USER": "<RABBITMQ_USER>",
"RABBITMQ_PASS": "<RABBITMQ_PASS>",
"KAFKA_BROKERS": "<KAFKA_BROKERS>",
"KAFKA_CLIENT_ID": "<KAFKA_CLIENT_ID>",
"KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
"KAFKA_SASL_USERNAME": "<KAFKA_SASL_USERNAME>",
"KAFKA_SASL_PASSWORD": "<KAFKA_SASL_PASSWORD>"
}
}
}
}Replace the values in angle brackets with your own. Keys stay on your machine; we never see them.
Tools
This server runs locally, so its tools are listed by your MCP client once it starts.
Environment variables
| Name | Description |
|---|---|
RABBITMQ_URLOptional | RabbitMQ Management API URL |
RABBITMQ_USEROptional, secret | RabbitMQ username |
RABBITMQ_PASSOptional, secret | RabbitMQ password |
KAFKA_BROKERSOptional | Comma-separated Kafka broker addresses |
KAFKA_CLIENT_IDOptional | Kafka client ID |
KAFKA_SASL_MECHANISMOptional | SASL mechanism: plain, scram-sha-256, scram-sha-512 |
KAFKA_SASL_USERNAMEOptional, secret | SASL username |
KAFKA_SASL_PASSWORDOptional, secret | SASL password |
Details
| Package | [email protected] (NPM, stdio) |
| First published | 14 Feb 2026 |
| Last updated | 14 Feb 2026 |
| Registry name | io.github.LarsCowe/queue-pilot |
More communication servers See all
Listing data from the official MCP registry. Status and tools from NestDaddy's daily check. Browse all MCP servers.