A
licenseC
qualityB
maintenanceReference implementation of KIP-1318, a secure Model Context Protocol server for Apache Kafka that enables AI agents to interact with Kafka clusters through governed tools and resources.
11
2
Apache 2.0
Best Apache Kafka MCP Servers
Apache Kafka is an open-source distributed event streaming platform used for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications.
Why this server?
Provides tools for managing Apache Kafka clusters, including listing and describing topics, consumer groups, cluster metadata, producing and consuming messages, creating and altering topics, and managing ACLs.
Why this server?
Provides integration with Apache Kafka through Lenses.io, enabling exploration, transformation, and joining of data in Kafka topics across multiple clusters using SQL queries without requiring an additional database.
AlicenseCqualityDmaintenanceManage, explore, transform and join data in Kafka topics across multiple clusters using different flavours of Apache Kafka via Lenses.io (including the free Community Edition)4228Apache 2.0Why this server?
Connects to EventCatalog instances that document Kafka-based architectures, enabling queries about event schemas, producers, consumers, and message flows
Alicense-qualityCmaintenanceA server that connects MCP clients (Claude, Cursor, Windsurf, etc.) to EventCatalog instances, allowing users to ask questions about their event-driven architecture and get insights about domains, services, and message schemas directly within their development tools.12623MITWhy this server?
Allows routing and queuing notifications through Apache Kafka for reliable message delivery.
Alicense-qualityCmaintenanceUnified notification MCP server with 36 tools to send messages across 23 channels — Email, SMS, Slack, Telegram, Discord, Teams, WhatsApp, Firebase Push, and more.1MITWhy this server?
Provides tools for managing Apache Kafka topics, messages, consumer groups, and cluster information with read/write access control and safety features.
Why this server?
Provides tools for managing Kafka clusters, topics, users, ACLs, connectors, and more on Kubernetes via the Strimzi operator.
Alicense-qualityAmaintenanceManage Apache Kafka on Kubernetes via Strimzi. Clusters, topics, users, connectors, MirrorMaker2, and node pools.91Apache 2.0Why this server?
Supports Kafka as both a streaming source and destination for data pipelines, enabling real-time data ingestion and processing.
Alicense-qualityBmaintenanceMCP server with 32 tools for ETL ingestion, AI-generated data quality rules, AI transformations, vector search, and natural-language SQL. Works across Postgres, MongoDB, Kafka, S3/MinIO, HashiCorp Vault, and five vector stores (Qdrant, Weaviate, Milvus, Chroma, pgvector).12AGPL 3.0Why this server?
Enables interaction with Apache Kafka topics, allowing read and write operations such as publishing messages to topics and consuming messages from topics in a Kafka instance.
Alicense-qualityDmaintenanceEnables interaction with Apache Kafka topics, allowing users to publish messages to and read messages from Kafka instances through natural language.Apache 2.0Why this server?
Provides tools for listing Kafka topics with partition count and replication factor, enabling AI agents to inspect Kafka clusters.
FlicenseCqualityBmaintenanceExposes Kafka administration operations as MCP tools, enabling AI agents to inspect Kafka clusters using natural language.1
