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 monitoring and management for Apache Kafka clusters, including cluster/topic metadata, consumer groups and lag, topic creation and configuration, partition management, offset resets, and guarded deletion of topics and consumer groups.
AlicenseAqualityBmaintenanceEnables MCP-capable clients to monitor and manage Apache Kafka clusters, including topics, partitions, configs, and consumer groups with lag, while enforcing configurable security modes, topic allowlists, protected topics, and audit logging.686 npm1MITWhy this server?
Provides tools for interacting with Apache Kafka clusters: inspecting cluster health, topics, partitions, configs, ACLs, consumer groups, lag, offsets, and open transactions; reading, searching, sampling, producing, and copying messages; and managing topics and consumer groups. Supports Schema Registry decoding and encoding where configured.
AlicenseAqualityBmaintenanceMCP server that exposes Kafka debugging to an LLM: find messages, measure lag, unblock consumers. Read-only endpoints, previews before writes.251MITWhy this server?
Provides tools for reading and searching Kafka messages through a Redpanda Console HTTP API, including listing topics, viewing cluster info, describing topic configurations, fetching messages by offset or timestamp, and searching message contents.
AlicenseAqualityCmaintenanceEnables AI assistants to read and search Kafka messages through the Redpanda Console HTTP API, including topic listing, message fetching by offset or time, and substring search, without direct Kafka broker access.710 npm1MITWhy this server?
Allows AI assistants to interact with Apache Kafka clusters via AKHQ's REST API, providing tools for managing topics, consumer groups, schema registry, nodes/brokers, Kafka Connect, ksqlDB, and ACLs.
AlicenseBqualityBmaintenanceEnables AI assistants to interact with Apache Kafka clusters through AKHQ's REST API. Supports multi-environment configuration, flexible authentication, and comprehensive coverage of topics, consumer groups, schema registry, Kafka Connect, ksqlDB, and ACLs.5811 npmMITWhy this server?
Enables AI agents to interact with Apache Kafka message clusters through the MCP protocol, allowing safe and efficient Kafka messaging operations.
AlicenseAqualityAmaintenanceEnables large language models and AI agents to securely and efficiently interact with Apache Kafka clusters through the Model Context Protocol.11Apache 2.0Why 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.
AlicenseCqualityBmaintenanceManage, 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?
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.
AlicenseCqualityDmaintenanceReference 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.112Apache 2.0Why this server?
Connects to EventCatalog instances that document Kafka-based architectures, enabling queries about event schemas, producers, consumers, and message flows
AlicenseNot gradedqualityFmaintenanceA 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.1,283 npm24MITWhy this server?
Provides tools for listing Kafka topics with partition count and replication factor, enabling AI agents to inspect Kafka clusters.
FlicenseCqualityDmaintenanceExposes Kafka administration operations as MCP tools, enabling AI agents to inspect Kafka clusters using natural language.1-