Message queues and event streaming are the nervous system of distributed systems — and now AI agents can produce messages, consume events, manage topics, monitor consumer lag, and orchestrate pipelines directly through MCP. Every major messaging platform has at least one MCP server, and several have official vendor-backed implementations.
The landscape splits into three tiers. Managed cloud services (Google Pub/Sub, AWS SQS/SNS, Azure Event Hubs) have official servers with IAM-native auth and zero infrastructure. Self-managed brokers (Kafka, RabbitMQ, Pulsar, NATS) have fragmented community ecosystems with varying quality. And protocol-level servers (MQTT, Redis Streams) serve specific niches in IoT and lightweight messaging.
What surprised us: Kafka has the most fragmented ecosystem with 10+ independent MCP servers and no clear community winner. Apache Pulsar quietly has the highest tool count of any messaging MCP server (70+ tools). NATS punches well above its market share with 42-tool servers that include built-in agent coordination primitives. And Google Pub/Sub ships the most architecturally sophisticated implementation — a fully managed remote endpoint that auto-enabled for customers in March 2026.
Disclosure: Our recommendations are based on research — analyzing documentation, GitHub repositories, community feedback, and published benchmarks. We have not hands-on tested every server in this guide.
At a Glance: Top Picks
| Category | Our pick | Stars | Runner-up |
|---|---|---|---|
| Kafka (Confluent Cloud) | confluentinc/mcp-confluent | 141 | — |
| Kafka (self-managed) | kanapuli/mcp-kafka | 76 | tuannvm/kafka-mcp-server (45) |
| Kafka Schema Registry | aywengo/kafka-schema-reg-mcp | 31 | — |
| RabbitMQ | amazon-mq/mcp-server-rabbitmq | 25 | kmitchell/rabbitmq-mcp (0) |
| Google Pub/Sub | Google Pub/Sub Remote MCP | Official | — |
| AWS SQS / SNS | awslabs/amazon-sns-sqs-mcp-server | Official | — |
| Azure messaging | microsoft/mcp | 2,800 (mono) | — |
| NATS | JesseObrien/nats-mcp | 0 | sinadarbouy/mcp-nats (39) |
| Apache Pulsar | Apache pulsar-java-contrib | 16 | streamnative/streamnative-mcp-server (23) |
| MQTT | Benniu/emqx-mcp-server | 23 | ezhuk/mqtt-mcp (12) |
| Redis Streams | redis/mcp-redis | 455 | — |
| IBM MQ | ibm-messaging/mq-mcp-server | 2 | — |
| Multi-protocol | LarsCowe/queue-pilot | 2 | — |
Apache Kafka
Kafka has the most fragmented MCP ecosystem of any messaging platform. At least 10 independent implementations exist, most offering similar produce/consume/list-topics functionality. The split is between Confluent Cloud users (who have one clear answer) and self-managed Kafka users (who have several options, none dominant).
confluentinc/mcp-confluent — The Winner (Confluent Cloud)
Stars: 141 | Language: TypeScript | Tools: 24+ | Transport: stdio, HTTP, SSE
Confluent’s official server is the only Kafka MCP that treats Kafka as part of a broader data streaming platform rather than just a message bus.
What makes it stand out:
- Beyond basic Kafka — topics, Flink SQL statement execution, Schema Registry management, Kafka Connect connector lifecycle, and Tableflow pipeline management
- Schema-aware consumption — consume messages with automatic Schema Registry deserialization
- Tool filtering — expose only the tools you need to keep LLM context lean
- Three transports — stdio, HTTP, and SSE. Most Kafka MCP servers are stdio-only
- Active development — Confluent maintains this as a core developer experience product
Limitations:
- Confluent Cloud only — does not work with self-managed Kafka
- Star count (141) is modest compared to Confluent’s user base, suggesting early adoption
- No consumer group management or lag monitoring
Best for: Confluent Cloud customers who want comprehensive Kafka + Flink + Schema Registry control from their AI assistant.
kanapuli/mcp-kafka — The Winner (Self-Managed)
Stars: 76 | Language: Go | License: MIT | Tools: 6 | Transport: stdio
The most adopted community Kafka server. Written in Go for easy single-binary deployment.
What makes it stand out:
- 6 clean tools — create topic, list topics, delete topic, describe topic, produce message, consume messages
- SASL auth — SASL_PLAINTEXT and PLAINTEXT authentication
- Go single binary — no runtime dependencies, easy Docker deployment
- 58 commits — actively maintained
Limitations:
- No consumer group management, no offset control, no Schema Registry
- No HTTP transport — stdio only
- Basic feature set compared to Confluent’s 24+ tools
Best for: Self-managed Kafka users who need simple topic and message operations without the Confluent Cloud dependency.
tuannvm/kafka-mcp-server — The Security-Conscious Alternative
Stars: 45 | Language: Go | License: MIT | Tools: 9 | Transport: stdio, HTTP
What makes it different: This Go server adds OAuth 2.1 for HTTP transport (Okta, Google, Azure AD), consumer lag analysis, cluster health monitoring, and broker listing. It supports SASL PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, and TLS — the widest auth coverage of any community Kafka server. Good choice when security compliance matters.
Other Kafka Servers Worth Knowing
| Server | Stars | Language | Tools | Notable |
|---|---|---|---|---|
| wklee610/kafka-mcp | 10 | Python | 16 | Consumer group management with offset reset/rewind. Updated March 2026 |
| brandon-powers/mcp-kafka | 3 | Python | 23 | Kafka Connect + Burrow consumer lag + Cruise Control integration. WIP |
| pavanjava/kafka_mcp_server | 17 | Python | 7 | Straightforward publish/consume/topic management |
| CefBoud/kafka-mcp-server | 3 | Go | 7 | MultiplexTool for batching, read-only mode, command logging, Gemini-powered argument inference |
aywengo/kafka-schema-reg-mcp — The Schema Specialist
Stars: 31 | Language: Python | License: MIT | Tools: 50+ (full mode), 9 (slim mode) | Version: v2.1.5
No other messaging platform has a dedicated schema management MCP server. This one manages up to 8 Schema Registry instances simultaneously — list registries, inspect subjects and schemas, register new schemas, check compatibility, create contexts (production, staging), and export schemas for backup/migration. The slim mode (9 tools) is useful for keeping LLM context small. Built on FastMCP 2.8.0+, MCP spec 2025-06-18 compliant.
AWS MSK Infrastructure
The awslabs/mcp monorepo (8,500 stars) includes an amazon-msk-mcp-server with 31 tools for MSK infrastructure management — cluster CRUD, broker storage/type/count updates, VPC connections, SCRAM secrets, tagging, and telemetry. This manages MSK infrastructure, not Kafka messages. Use it alongside a Kafka MCP server for message operations.
RabbitMQ
RabbitMQ’s MCP ecosystem is small but practical, with Amazon MQ providing the official implementation.
amazon-mq/mcp-server-rabbitmq — The Winner
Stars: 25 | Language: Python | License: Apache-2.0 | Transport: stdio, HTTP
Amazon MQ’s official RabbitMQ server. Dynamically generates tools from RabbitMQ’s admin APIs, supports multi-broker connections (manage multiple RabbitMQ instances in a single session), and uses OAuth token authentication. Originally created by kenliao94 (an AWS engineer, whose fork has 39 stars) and migrated to the official amazon-mq org.
Limitations:
- Dynamically generated tools means the tool count varies by RabbitMQ version
- Documentation is sparse
- OAuth setup can be complex for self-managed RabbitMQ
kmitchell/rabbitmq-mcp — The Operations Tool
Stars: 0 | Language: TypeScript | License: MIT
Takes a practical approach: get message counts, move messages between queues, purge dead-letter queues, check for alarms. Wraps the RabbitMQ HTTP Management API (management plugin must be enabled). Good complement to the Amazon MQ server for day-to-day operations.
Google Cloud Pub/Sub
Google Pub/Sub Remote MCP — The Winner
Transport: Remote HTTP (managed) | Tools: 15 | Auth: OAuth 2.0 + IAM
The most architecturally sophisticated messaging MCP server. Google ships Pub/Sub MCP as a fully managed remote endpoint — no installation, no local server, no SDK. Just point your MCP client at the endpoint and authenticate with Google Cloud credentials.
What makes it stand out:
- 15 tools — full CRUD for topics, subscriptions, and snapshots, plus publish
- IAM-native auth — uses your existing Google Cloud IAM policies. No separate API keys
- Model Armor protection — Google’s AI safety layer filters requests
- Audit logging — all operations logged in Cloud Audit Logs
- Auto-enabled — after March 17, 2026 for existing Pub/Sub customers
- Global and regional endpoints — choose data residency
Limitations:
- No API key auth — must use OAuth 2.0 (harder for quick prototyping)
- No consume/pull operations — you can publish but not read messages via MCP
- Google Cloud only — not usable with self-managed Pub/Sub emulators
Best for: Google Cloud teams who want zero-infrastructure Pub/Sub management. The IAM integration is the gold standard for secure messaging MCP.
AWS SQS / SNS / EventBridge
amazon-sns-sqs-mcp-server — The Winner
Language: Python | License: Apache-2.0 | Transport: stdio | Auth: AWS IAM
Part of the awslabs/mcp monorepo (8,500 stars). Covers both SQS and SNS in a single server.
What makes it stand out:
- Tag-based safety — only modifies resources that were created by the MCP server (tagged with
CreatedBy: MCP). Won’t accidentally delete your production queues - Resource creation disabled by default — must explicitly pass
--allow-resource-creationto enable create operations - SNS + SQS unified — topics, subscriptions, and queues in one server
- A2P messaging disabled — SMS/phone messaging blocked as a safety measure
Limitations:
- No EventBridge, Kinesis, or MSK in this server (those are in separate servers in the monorepo)
- Standard AWS IAM auth — requires AWS_PROFILE and AWS_REGION setup
- No dead-letter queue management
AWS Serverless MCP Server — EventBridge + Kinesis
Also in the awslabs/mcp monorepo. Covers EventBridge schema registry (list, search, describe schemas) and event source mapping tools for Kinesis, SQS, DynamoDB Streams, and MSK. Includes SAM template generation for serverless event processing. Not a dedicated EventBridge or Kinesis server — more of a serverless orchestration tool.
Gap: No dedicated Kinesis MCP server exists. No dedicated EventBridge MCP server exists. These are the biggest AWS messaging gaps.
Azure Service Bus / Event Hubs / Event Grid
microsoft/mcp — The Winner
Stars: 2,800 (monorepo) | Language: C# | License: MIT | Transport: stdio
Microsoft’s unified Azure MCP server covers all three messaging services, but with uneven depth.
Service Bus (3 tools): Read-only — get queue runtime details (message counts, status), topic runtime details, subscription runtime details. No create, delete, or publish operations.
Event Hubs (8 tools): Full CRUD — create/update/delete Event Hubs, namespaces, and consumer groups. Configure partition count, retention, Kafka support, auto-inflate, zone redundancy.
Event Grid (3 tools): List topics, publish events (with schema validation), list subscriptions with filtering.
Total: ~14 messaging tools across three services.
Limitations:
- Service Bus is read-only — you can’t send messages or manage queues via MCP
- Event Hubs is the strongest, Event Grid and Service Bus are thin
- Requires Azure identity auth — no API key option
- Previous standalone repo (Azure/azure-mcp, 1,200 stars) was archived August 2025
Best for: Azure teams who need Event Hubs management. Service Bus users will find the read-only tooling limiting.
NATS / NATS JetStream
NATS punches well above its market share in the MCP ecosystem. The lightweight messaging system has surprisingly comprehensive coverage, including the only messaging MCP server with built-in agent coordination primitives.
JesseObrien/nats-mcp — The Winner
Stars: 0 | Language: Go | License: MIT | Tools: 42 | Transport: stdio
The highest tool count of any NATS MCP server, organized across 7 groups:
- Core Messaging (5) — publish, subscribe, request/reply, queue groups
- JetStream Streams (5) — create, list, info, purge, delete streams
- JetStream Consumers (5) — create, list, info, delete consumers, consume messages
- Key-Value (7) — create, put, get, delete, list keys, watch, history
- Object Store (7) — create, put, get, delete, list, info, seal
- Server & Services (4) — server info, connections, service discovery
- Agent Coordination (9) — distributed locks, leader election, task queues, work assignment, heartbeat monitoring, agent registration, status tracking
What makes it stand out:
- Embedded NATS server — no external infrastructure needed. The MCP server starts its own NATS instance
- Agent coordination primitives — the 9 coordination tools are unique in the messaging MCP space. Designed for multi-agent workflows
- Full JetStream support — persistence, exactly-once delivery, replay
Limitations:
- Zero stars suggests very early/undiscovered
- Embedded server means it’s not managing your production NATS cluster
- No SSE transport
sinadarbouy/mcp-nats — The Production Alternative
Stars: 39 | Language: Go | License: Apache-2.0 | Transport: stdio, SSE
Connects to external NATS clusters (not embedded). Multi-account support, backup/restore, credential and user/password auth. MCP Review certified. Better suited for managing existing NATS infrastructure than JesseObrien’s embedded approach.
Other NATS Servers
| Server | Stars | Language | Tools | Notable |
|---|---|---|---|---|
| Gooseus/mcp-nats | 0 | TypeScript | 24 | SSE transport, documentation tools. Good TypeScript alternative |
| bmorphism/nats-mcp-server | 7 | TypeScript | 3 | Minimal: publish, subscribe, request |
Note: hofer/nats-mcp is a transport bridge (exposes existing MCP servers over NATS), not a NATS management tool.
Apache Pulsar
Pulsar has the highest raw tool count of any messaging platform in the MCP ecosystem, though with lower community adoption.
Apache pulsar-java-contrib — The Winner
Stars: 16 | Language: Java | License: Apache-2.0 | Tools: 70+ | Transport: stdio, HTTP streaming
Part of the official Apache Pulsar contrib repository. The 70+ tools cover cluster, tenant, namespace, topic, and subscription management plus schema operations, monitoring, backlog analysis, and message send/receive. This is the most comprehensive messaging MCP server by tool count.
Limitations:
- Java-only — heavier runtime than Go or TypeScript alternatives
- Low star count (16) despite being official Apache contrib
- Requires running Pulsar infrastructure
streamnative/streamnative-mcp-server — The Multi-Protocol Bridge
Stars: 23 | Language: Go | License: Not specified | Tools: 40+ | Transport: stdio, SSE
StreamNative’s official server bridges Kafka and Pulsar in a single MCP server. Dynamic function-as-tool exposure, feature toggling via --features flag, multi-session Pulsar mode with LRU caching. Available via Homebrew and Docker. Connects to StreamNative Cloud, direct Kafka clusters, or direct Pulsar clusters.
Best for: StreamNative customers or teams running both Kafka and Pulsar who want unified management.
MQTT / IoT Messaging
MQTT’s MCP ecosystem serves the IoT and edge computing space with 5+ servers of varying scope.
Benniu/emqx-mcp-server — The Winner
Stars: 23 | Language: Python | License: Apache-2.0 | Tools: 5 | Transport: stdio, SSE
The most adopted MQTT MCP server. Connects to EMQX Cloud or self-hosted EMQX clusters. Lists clients, kicks clients, publishes messages with QoS 0/1/2, subscribes with configurable duration (1-300 seconds).
ezhuk/mqtt-mcp — The Developer-Friendly Alternative
Stars: 12 | Language: Python | License: MIT | Tools: 2 + resources + prompts | Transport: stdio
Simpler than EMQX but with better developer experience — Docker deployment, multi-client SDK examples (OpenAI, PydanticAI), and a Building Automation/Industrial Control/Smart Home focus. Updated March 2026 (v0.3.1).
Other MQTT Servers
| Server | Stars | Language | Tools | Notable |
|---|---|---|---|---|
| tspspi/mcpMQTT | 1 | Python | 4 | Fine-grained topic permissions with wildcard matching, Argon2id auth, request/response patterns |
| ysfscream/mqttx-mcp-sse-server | 5 | JavaScript | 3 | SSE transport for persistent connections, multi-client sessions |
| poly-mcp/IoT-Edge-MCP-Server | 22 | Python | 13+ | MQTT + Modbus unified, InfluxDB + Redis backend, SCADA/IoT focus |
Note: mqtt-ai/mcp-over-mqtt is a transport layer (routes MCP traffic over MQTT), not an MCP server for MQTT operations.
Redis Streams / Pub/Sub
redis/mcp-redis — The Winner
Stars: 455 | Language: Python | License: MIT | Transport: stdio
Redis’s official MCP server includes Streams and Pub/Sub alongside its broader Redis toolset. Streams tools cover xadd, xread, xdel with consumer group support. Pub/Sub tools cover publish and subscribe. The 455-star count makes this the most popular server in our entire comparison — though most users are here for Redis data structures, not just messaging.
Limitation: This is a general Redis server, not a dedicated messaging server. The Streams/Pub/Sub tools are a subset of the full toolset.
IBM MQ
ibm-messaging/mq-mcp-server — The Winner (by Default)
Stars: 2 | Language: Python | License: Apache-2.0 | Tools: 2 | Transport: Streamable HTTP
IBM’s official MQ MCP server. Two tools: dsqmq (list queue managers and status) and runmqsc (execute any MQSC command). The runmqsc tool is essentially a raw command escape hatch — you send MQSC commands as strings and get raw output back. No safety guardrails, no structured responses.
Limitations:
- Only 2 tools — the lowest of any official vendor server
runmqschas no input validation or confirmation- Requires Python 3.10+, mqweb server, and MQ distributed installation
- 2 stars and last commit July 2025 suggest minimal investment
Best for: IBM MQ shops that need basic queue manager inspection. Don’t expect a polished experience.
Multi-Protocol
LarsCowe/queue-pilot — The Universal Option
Stars: 2 | Language: TypeScript | License: MIT | Tools: 29 | Transport: stdio
The only MCP server that works across multiple message brokers. Currently supports RabbitMQ and Apache Kafka with 18 universal tools + 7 RabbitMQ-specific + 4 Kafka-specific. Includes JSON Schema validation for messages, peek-without-consuming, and schema-gated publishing.
Limitations:
- Only 2 brokers supported (RabbitMQ + Kafka)
- 2 stars and February 2026 last commit suggest early stage
- No NATS, Pulsar, or cloud service support
Best for: Teams running both RabbitMQ and Kafka who want a single MCP server instead of two.
Decision Flowchart
Using Confluent Cloud? → confluentinc/mcp-confluent. No contest.
Self-managed Kafka? → kanapuli/mcp-kafka for basics. Add aywengo/kafka-schema-reg-mcp if you use Schema Registry. Consider tuannvm/kafka-mcp-server if you need OAuth 2.1 or consumer lag analysis.
Google Cloud? → Google Pub/Sub Remote MCP. Zero infrastructure, IAM-native.
AWS? → amazon-sns-sqs-mcp-server for SQS/SNS. Add amazon-msk-mcp-server if you’re on MSK.
Azure? → microsoft/mcp for Event Hubs (full CRUD). Service Bus is read-only.
RabbitMQ? → amazon-mq/mcp-server-rabbitmq.
NATS? → JesseObrien/nats-mcp if you want an embedded server with agent coordination. sinadarbouy/mcp-nats if you’re connecting to an existing cluster.
Pulsar? → Apache pulsar-java-contrib for 70+ tools. streamnative/streamnative-mcp-server for Kafka+Pulsar bridge.
MQTT/IoT? → Benniu/emqx-mcp-server.
Multiple brokers? → LarsCowe/queue-pilot for RabbitMQ + Kafka.
Three Trends
1. Official vendors are showing up — unevenly. Confluent, Google, AWS, Microsoft, Redis, IBM, Amazon MQ, StreamNative, and Apache all have official MCP servers. But the quality ranges from Google’s polished managed endpoint (15 tools, IAM, audit logging) to IBM’s 2-tool escape hatch. Official ≠ comprehensive.
2. The Kafka ecosystem is the most fragmented in all of MCP. 10+ independent implementations, most with <20 stars, all offering similar produce/consume/list-topics. This fragmentation will likely consolidate as Confluent’s official server matures. For self-managed Kafka, no single community server has achieved escape velocity.
3. Agent coordination is emerging as a messaging use case. NATS’s JesseObrien/nats-mcp includes 9 agent coordination tools (distributed locks, leader election, task queues, heartbeat monitoring). This signals that messaging MCP servers are evolving from “let me manage my broker” to “let agents coordinate through my broker.” Expect more servers to add multi-agent primitives.
What’s Missing
- No dedicated Amazon Kinesis MCP server — Kinesis is handled via ESM tools in the serverless MCP server, not direct stream operations
- No dedicated AWS EventBridge MCP server — same situation, bundled into serverless
- No Apache ActiveMQ MCP server — ActiveMQ, one of the oldest Java message brokers, has zero MCP presence
- Azure Service Bus is read-only — you can check queue depth but can’t send messages
- No RocketMQ MCP server — Apache RocketMQ, popular in China, has no MCP server
- No ZeroMQ MCP server — the lightweight messaging library has no MCP integration
- No message replay/reprocessing tools — no server offers dead-letter queue analysis, message replay from offsets, or failed message investigation workflows
- No cross-broker migration tools — can’t move topics/queues between Kafka and RabbitMQ, or migrate from one cloud provider to another
- No unified monitoring — no server provides cross-broker consumer lag, throughput, or health dashboards
Last updated: March 2026. Star counts and tool counts are from our research and may have changed. See our full review of message queue MCP servers for individual server details, or browse our master MCP server guide for all categories.