Queue Pilot

本地 MCP 服务器，用于检查 RabbitMQ 与 Kafka 消息，并对消息负载做 JSON Schema 校验。

可以做什么

• 通过 RabbitMQ Management API 查看队列与消息。
• 通过已配置的 broker 查看 Kafka 主题与消息。
• 用 JSON Schema 校验消息负载。
• 以可选的 SASL 认证（plain、scram-sha-256、scram-sha-512）连接 Kafka。

适用场景

适合在调试、联调或核对生产消息是否符合预期结构时，让助手查看 RabbitMQ 或 Kafka 中流转的消息。

运行要求

以 npm 包形式通过 npx 在本地以 stdio 运行（需要 Node.js），仅限桌面环境。需要可访问的 RabbitMQ Management API 地址及 RabbitMQ 凭据，以及 Kafka broker 地址和客户端 ID；若 broker 要求认证，还需 SASL 机制与凭据。需要能访问这些 broker 与管理 API 的网络。