Queue Pilot
MCP server for RabbitMQ and Kafka message inspection with JSON Schema validation
MCP-сервер · от LarsCowe
Коротко
Queue Pilot: MCP-сервер, издатель LarsCowe. Витрин, которые мы читаем и где он опубликован: 1 (Official MCP Registry). Мы впервые увидели его 2026-10-11 и с тех пор изменений не фиксировали. Данные нашего прохода по витринам на 2026-10-15.
Что просит
- Работает на вашем компьютере
- Секретов: 4
- Настроек: 8
Требует: KAFKA_SASL_PASSWORD (секрет), KAFKA_SASL_USERNAME (секрет), RABBITMQ_PASS (секрет), RABBITMQ_USER (секрет), --schemas
Что объявляет, просит и запускает, полностью
Устанавливайте плагины только от разработчиков, которым доверяете. Мы показываем то, что публикуют витрины, и не проверяем плагины.
Пакет
npm queue-pilot (queue-pilot на npm)
- Загрузки npm за неделю: 38 (2026-10-13)
- Загрузки npm за месяц: 188 (2026-10-13)
- Последняя версия на npm: 0.5.3, опубликована 2026-02-14
В OSV нет известных уязвимостей для 0.5.1 (проверено 2026-10-14)
Данные npm взяты из публичного реестра npm (registry.npmjs.org, api.npmjs.org). Каждое число принадлежит своему реестру и никогда не складывается с другим. Реестр, который не публикует число, ничего не показывает: нет числа не значит ноль. Записи об уязвимостях взяты из OSV.dev (CC BY 4.0) и относятся только к объявленной версии; листинг без объявленной версии ответа не получает. Код мы не сканируем.
Работает с
- Claude Code
- Codex
- Cursor
- VS Code
- Copilot CLI
По маркетплейсам, где он опубликован, и объявленному транспорту MCP, как их документирует каждый клиент. Плагины мы не тестируем.
Подключить
Команды и конфигурации собраны только из того, что объявляют витрины. Мы не запускаем их за вас и не проверяем плагины.
Как локальный MCP-сервер: пакет npm
Собрано из того, что объявляет Official MCP Registry.
claude mcp add --env "KAFKA_SASL_PASSWORD=<YOUR_KAFKA_SASL_PASSWORD>" --env "KAFKA_SASL_USERNAME=<YOUR_KAFKA_SASL_USERNAME>" --env "RABBITMQ_PASS=<YOUR_RABBITMQ_PASS>" --env "RABBITMQ_USER=<YOUR_RABBITMQ_USER>" --transport stdio queue-pilot -- npx -y queue-pilot --schemas "<YOUR_SCHEMAS>"
[mcp_servers.queue-pilot]
command = "npx"
args = ["-y", "queue-pilot", "--schemas", "<YOUR_SCHEMAS>"]
[mcp_servers.queue-pilot.env]
KAFKA_SASL_PASSWORD = "<YOUR_KAFKA_SASL_PASSWORD>"
KAFKA_SASL_USERNAME = "<YOUR_KAFKA_SASL_USERNAME>"
RABBITMQ_PASS = "<YOUR_RABBITMQ_PASS>"
RABBITMQ_USER = "<YOUR_RABBITMQ_USER>"
{
"mcpServers": {
"queue-pilot": {
"command": "npx",
"args": [
"-y",
"queue-pilot",
"--schemas",
"<YOUR_SCHEMAS>"
],
"env": {
"KAFKA_SASL_PASSWORD": "<YOUR_KAFKA_SASL_PASSWORD>",
"KAFKA_SASL_USERNAME": "<YOUR_KAFKA_SASL_USERNAME>",
"RABBITMQ_PASS": "<YOUR_RABBITMQ_PASS>",
"RABBITMQ_USER": "<YOUR_RABBITMQ_USER>"
}
}
}
}
Замените значения в угловых скобках своими. Мы показываем имена настроек, но не значения.
Необязательные аргументы, которые он тоже объявляет: --broker.
Необязательные настройки, которые он тоже перечисляет: KAFKA_BROKERS, KAFKA_CLIENT_ID, KAFKA_SASL_MECHANISM, RABBITMQ_URL.
Где опубликован
| Витрина | Статус | Версия | Числа | Проверен | Впервые замечен |
|---|---|---|---|---|---|
| Official MCP Registry (Открыть запись реестра) | Опубликован | 0.5.1 | Загрузки за месяц (npm): 188 Загрузки за неделю (npm): 38 |
Не помечен |
Каждое число принадлежит своей витрине и никогда не складывается с числами других витрин. Если витрина число не публикует, мы его не показываем: нет числа не значит ноль.
Что менялось
С тех пор как мы следим за плагином, ничего не менялось.
Похожие плагины
Продукты, чьи собственные названия, описания, инструменты и скиллы ближе всего по смыслу к этому, на всех витринах, которые мы читаем. Близость упорядочена только внутри этого списка.
-
Debug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters.
-
Async message queue for AI agents. Self-provision queues, push/poll messages, no signup.
-
Search @imqueue docs and scaffold typed services & clients from your AI coding agent.
-
sentinal-mcp io.github.Musaraf-M/sentinal-mcp
Redis health, BullMQ queue monitoring, memory analysis, and slow query diagnostics
-
mcp-kafka io.github.infoinlet-marketplace/mcp-kafka
Read-only Kafka for AI agents — topics, offsets, consumer groups, peek messages, health.
-
rabbitmq-elasticsearch-mysql-stack-generator ai.getvda/rabbitmq-elasticsearch-mysql-stack-generator
RabbitMQ + Elasticsearch + MySQL Stack Generator
-
rabbitmq-elasticsearch-postgres-stack-generator-mongo ai.getvda/rabbitmq-elasticsearch-postgres-stack-generator-mongo
RabbitMQ + Elasticsearch + Postgres Stack Generator (Mongo)
-
Provision PostgreSQL, manage Apache Kafka, and deploy apps with Aiven - all from your AI assistant.
-
Generate Apache Kafka producer/consumer setup
-
Read-only Kafka observability MCP server: cluster health, consumer lag, and replay-readiness.
Похожие плагины по витринам
Тот же вопрос к каждой витрине по отдельности: есть ли там аналог этого плагина?
Есть на витрине Claude Code: claude-plugins-community (5)
-
Skills and generators for working with the Go Watermill messaging library. Includes comprehensive reference guides for Routers, Pub/Sub implementations, CQRS, and middleware.
-
Easily deploy managed PostgreSQL (pg), Kafka, OpenSearch, Clickhouse and other databases, streaming and apps. Free tier available, up and running in minutes.
-
Detect breaking and non-breaking API schema changes across OpenAPI, GraphQL, and gRPC
-
Collection of official CrateDB agent skills
-
TestMesh MCP server + skills for writing and running E2E integration tests across HTTP, databases, Kafka, gRPC, WebSocket, and more.
Есть на витрине Claude Code: claude-plugins-official (5)
-
Easily deploy managed PostgreSQL (pg), Kafka, OpenSearch, Clickhouse and other databases, streaming and apps. Free tier available, up and running in minutes.
-
Skills for streaming application developers, covering Kafka and Flink client libraries and Schema Registry
-
Add Logfire observability to Python applications with auto-instrumentation for FastAPI, httpx, asyncpg, SQLAlchemy, and more
-
Hosted MCP server for AI-assisted Grafana Cloud observability — no local installation required.
-
Detect an MCP server's language (Python, TypeScript or Go) and instrument it with the matching Pendo SDK so MCP tool calls flow into Pendo Agent Analytics.
Есть на витрине Claude: knowledge-work-plugins (5)
-
Official SigNoz plugin for MCP setup, docs, queries, dashboards, and alerts
-
Hosted MCP server for AI-assisted Grafana Cloud observability — no local installation required.
-
Skills, agents, and workflows for Honeycomb observability — query patterns, production investigations, SLOs, OpenTelemetry instrumentation, and Beeline migration. Designed to…
-
Use Datadog directly in Claude Code through a preconfigured Datadog MCP server. Query logs, metrics, traces, dashboards, and more through natural conversation. This plugin is in…
-
Connect Claude to your ClickHouse Cloud databases. Browse organizations, services, databases, and table schemas. Run read-only SQL queries against your data and get instant…
Есть на витрине Codex: openai-curated (openai/plugins) (5)
-
Comprehensive skill for the entire Temporal lifecycle — developing applications, using the Temporal CLI, running and managing Temporal Server, and working with Temporal Cloud.
-
Available for US1 customers only. Analyze, investigate, and act on your Datadog telemetry directly from ChatGPT using natural language. Ask questions about your production…
-
CrowdStrike Falcon Fusion skills for authoring, deploying, and executing Fusion workflows. Includes live action discovery, YAML authoring with schema validation, workflow import…
-
CrowdStrike Falcon Foundry development skills for building cybersecurity applications on the Falcon platform. Includes UI development, collections, functions, workflows, API…
-
Inspect recent issues and events in Sentry from Codex.
Есть на витрине Community GitHub marketplaces (5)
-
Generate Apache Kafka producer/consumer setup
-
basicdeploy-mcp io.github.AkaciaNL/basicdeploy-mcp
The runtime your agent deploys to — DB, storage, and a public URL in one MCP call.
-
Author, run, and schedule iceDQ data quality rules, bundled with the iceDQ MCP server.
-
Every Better Stack Uptime feature, plus an offline SQLite mirror and cross-resource fleet analytics
-
Observability hooks, protocol enforcement, and the thoughtbox CLI
Есть на витрине Copilot CLI: github/awesome-copilot (5)
-
Explore and query TimeBase streams, schemas, QQL, symbols, and server status via MCP.
-
Safe BLE diagnostics, evidence workflows, and guarded automation for AI agents.
-
Use Datadog directly in Copilot / VS Code through a preconfigured Datadog MCP server. Query logs, metrics, traces, dashboards, and more through natural conversation.
-
Complete toolkit for building Model Context Protocol (MCP) servers in Go using the official github.com/modelcontextprotocol/go-sdk. Includes instructions for best practices, a…
-
Interactive GitHub Copilot canvas for discovering, connecting, and managing hosted MCP servers from an Azure Connector Namespace.
Есть на витрине Copilot CLI: github/copilot-plugins (5)
-
Toolkit for building Microsoft 365 Copilot declarative agents — scaffolding, JSON manifest development, and capability configuration.
-
mcp-apps
Generate MCP App widgets for MCP tools. Produces self-contained HTML widgets using the MCP Apps protocol.
-
workiq
Query Microsoft 365 data with natural language — emails, meetings, documents, Teams messages, and more.
-
Build Power Apps Canvas Apps using the Canvas Authoring MCP server.
-
model-apps
Build and deploy Power Apps generative pages for model-driven apps with specialist agents for planning, entity creation, and parallel code generation. Requires PAC CLI >= 2.7.0…
Есть на витрине Cursor: cursor/plugins (5)
-
Fan large tasks out across parallel cloud agents with planners, workers, verifiers, and structured handoffs.
-
CLI-backed repo compatibility scans plus agents that audit startup, validation, and docs against reality.
-
Build apps, scripts, and automations with the TypeScript SDK.
-
Inspect and manage feature gates, experiments, dynamic configs, and metrics.
-
Let Grok Bot reach MCP servers on your private Tailscale network. Sign in to Tailscale to connect your tailnet; Grok Bot joins it as one tagged device and only reaches the hosts…
Есть на витрине Docker MCP Catalog (5)
-
Comprehensive MCP server for Kafka Schema Registry operations. Features multi-registry support, schema contexts, migration tools, OAuth authentication, and 57+ tools for complete…
-
mcp-server-couchbase io.github.Couchbase-Ecosystem/mcp-server-couchbase
Couchbase Model Context Protocol Server to interact with Couchbase clusters
-
Give your AI agents trusted access to the full Postman platform.
-
testkube-mcp io.github.kubeshop/testkube-mcp
MCP server for Testkube - Manage test workflows, executions, and artifacts via AI assistants
-
MCP server providing Prometheus metrics access and PromQL query execution for AI assistants
Есть на витрине Official MCP Registry (5)
-
Debug Kafka from an agent: find messages, measure consumer lag, unblock consumers, compare clusters.
-
Async message queue for AI agents. Self-provision queues, push/poll messages, no signup.
-
Search @imqueue docs and scaffold typed services & clients from your AI coding agent.
-
sentinal-mcp io.github.Musaraf-M/sentinal-mcp
Redis health, BullMQ queue monitoring, memory analysis, and slow query diagnostics
-
mcp-kafka io.github.infoinlet-marketplace/mcp-kafka
Read-only Kafka for AI agents — topics, offsets, consumer groups, peek messages, health.
Найдено по смыслу, а не по общему коду или репозиторию: похожие плагины остаются разными продуктами, и это не обзор и не рекомендация.
Это ваш плагин?
Добавьте плагин в свои проекты и докажите, что поддерживаете его: файлом в репозитории, файлом на вашем домене или DNS-записью. Вы будете получать уведомления, когда витрина добавит плагин, снимет его, изменит отметку verified или список того, что он просит, а его удалённый endpoint встанет на мониторинг как веб-сервис.
Данные витрины Official MCP Registry. Числа взяты из наших регулярных обходов витрин, последняя проверка . Контакты издателей плагинов мы не публикуем.