Kafka MCP Server

What is Kafka MCP Server?

Kafka MCP Server is a Model Context Protocol (MCP) server for Apache Kafka implemented in Go. It bridges LLM models with Kafka, enabling them to produce and consume messages, manage topics and consumer groups, and assess cluster health through the standardized MCP interface.

How to use Kafka MCP Server?

Install via Homebrew on macOS/Linux with brew tap tuannvm/mcp && brew install kafka-mcp-server, or build from source with go build -o kafka-mcp-server ./cmd. Configure MCP clients like Cursor, Claude Desktop, Claude Code, or ChatWise by editing JSON configuration files and setting environment variables such as KAFKA_BROKERS, KAFKA_CLIENT_ID, and MCP_TRANSPORT. Optionally use the companion tool mcpenetes to manage configurations across clients.

Key features of Kafka MCP Server

• Support for SASL (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512) and TLS authentication.
• OAuth 2.1 authentication for HTTP transport (Native and Proxy modes).
• Flexible transport: STDIO for local clients, HTTP for remote access.
• Pre-configured prompts for common Kafka operations and diagnostics.
• Provides tools, resources, and prompts via the MCP protocol.
• Compatible with MCP-compatible LLM models.

Use cases of Kafka MCP Server

• Help an AI assistant investigate consumer lag and cluster health.
• Allow an LLM to produce and consume messages from Kafka topics.
• Enable an LLM to list, describe, and manage topics and consumer groups.
• Let an LLM monitor cluster health and configuration through standard MCP.