AgentHubAgentHub

Queue Pilot

MCP ServerMCP Registry官方收录

io.github.LarsCowe/queue-pilot · v0.5.1

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

概览

Queue Pilot 是一个MCP Server,收录自 官方 MCP Registry。支持 stdio 传输。本页提供 Cursor、Claude Code 等客户端的安装配置片段。

安装

选择你的平台查看安装方式

{
  "mcpServers": {
    "queue-pilot": {
      "command": "npx",
      "args": [
        "-y",
        "queue-pilot"
      ]
    }
  }
}

环境变量

RABBITMQ_URL可选

RabbitMQ Management API URL

RABBITMQ_USER可选secret

RabbitMQ username

RABBITMQ_PASS可选secret

RabbitMQ password

KAFKA_BROKERS可选

Comma-separated Kafka broker addresses

KAFKA_CLIENT_ID可选

Kafka client ID

KAFKA_SASL_MECHANISM可选

SASL mechanism: plain, scram-sha-256, scram-sha-512

KAFKA_SASL_USERNAME可选secret

SASL username

KAFKA_SASL_PASSWORD可选secret

SASL password

相关资源

统一 Manifest

{
  "id": "io.github.LarsCowe/queue-pilot",
  "type": "mcp-server",
  "version": "0.5.1",
  "displayName": "Queue Pilot",
  "description": "MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation",
  "repository": {
    "url": "https://github.com/LarsCowe/queue-pilot",
    "source": "github"
  },
  "homepage": "https://github.com/LarsCowe/queue-pilot#readme",
  "distribution": {
    "packages": [
      {
        "registryType": "npm",
        "identifier": "queue-pilot",
        "version": "0.5.1",
        "runtimeHint": "npx",
        "transport": "stdio",
        "environmentVariables": [
          {
            "name": "RABBITMQ_URL",
            "description": "RabbitMQ Management API URL"
          },
          {
            "name": "RABBITMQ_USER",
            "description": "RabbitMQ username",
            "isSecret": true
          },
          {
            "name": "RABBITMQ_PASS",
            "description": "RabbitMQ password",
            "isSecret": true
          },
          {
            "name": "KAFKA_BROKERS",
            "description": "Comma-separated Kafka broker addresses"
          },
          {
            "name": "KAFKA_CLIENT_ID",
            "description": "Kafka client ID"
          },
          {
            "name": "KAFKA_SASL_MECHANISM",
            "description": "SASL mechanism: plain, scram-sha-256, scram-sha-512"
          },
          {
            "name": "KAFKA_SASL_USERNAME",
            "description": "SASL username",
            "isSecret": true
          },
          {
            "name": "KAFKA_SASL_PASSWORD",
            "description": "SASL password",
            "isSecret": true
          }
        ]
      }
    ],
    "remotes": []
  },
  "dependencies": [],
  "installTargets": [
    "claude-code",
    "claude-desktop",
    "cursor",
    "vscode"
  ],
  "keywords": [],
  "provenance": {
    "origin": "official-mcp-registry",
    "originalId": "io.github.LarsCowe/queue-pilot",
    "originalUrl": "https://registry.modelcontextprotocol.io/v0.1/servers/io.github.LarsCowe%2Fqueue-pilot/versions/latest",
    "isOfficial": true,
    "status": "active"
  }
}
Queue Pilot — MCP Server 安装与配置 · AgentHub