Queue Pilot

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

stdio v0.5.1

Connection Configuration

Add this to your AI agent's MCP config file to connect.

Run in your terminal:

claude mcp add io.github.larscowe--queue-pilot -- npx

Transport

stdio

Authentication

None

Version

v0.5.1

Server Name

io.github.LarsCowe/queue-pilot

Last Updated

Feb 14, 2026

How to install and connect this MCP server.

Environment variables you must provide when running this server.

Variable	Description	Required
`RABBITMQ_URL`	RabbitMQ Management API URL	Optional
`RABBITMQ_USER` secret	RabbitMQ username	Optional
`RABBITMQ_PASS` secret	RabbitMQ password	Optional
`KAFKA_BROKERS`	Comma-separated Kafka broker addresses	Optional
`KAFKA_CLIENT_ID`	Kafka client ID	Optional
`KAFKA_SASL_MECHANISM`	SASL mechanism: plain, scram-sha-256, scram-sha-512	Optional
`KAFKA_SASL_USERNAME` secret	SASL username	Optional
`KAFKA_SASL_PASSWORD` secret	SASL password	Optional