Credits
@CefBoud
About Credits
No overview available yet
Basic information
Config
Add this server to your MCP-compatible client using the configuration below.
{
"mcpServers": {
"kafka": {
"command": "docker",
"args": [
"run",
"-i",
"--rm",
"-e",
"KAFKA_MCP_BOOTSTRAP_SERVERS",
"ghcr.io/cefboud/kafka-mcp-server"
],
"env": {
"KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
}
}
}
}Tools
No tools detected
We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.
Overview
What is Kafka MCP Server?
The Kafka MCP Server is a Model Context Protocol (MCP) server that provides integration with Apache Kafka, enabling interaction with a Kafka cluster using natural language via LLMs.
How to use Kafka MCP Server?
Requires Docker or Go to run locally, and access to a Kafka cluster. Configure with the KAFKA_MCP_BOOTSTRAP_SERVERS environment variable or --bootstrap-servers flag. Can be run via Docker image ghcr.io/cefboud/kafka-mcp-server or built from source.
Key features of Kafka MCP Server
- List and create topics
- Consume and produce messages
- Describe cluster (brokers and controller)
- List consumer groups and their lag
- Get topic's earliest and latest offsets
- MultiplexTool for batching sequential tool calls
Use cases of Kafka MCP Server
- Monitor Kafka topics and consumer groups via natural language
- Automate topic creation and message production from LLM chat
- Debug cluster state and broker information interactively
- Execute multi-step Kafka operations in a single request using MultiplexTool
FAQ from Kafka MCP Server
What are the prerequisites?
Docker or Go, and a running Kafka cluster. The quickstart uses docker run -p 9092:9092 apache/kafka:4.0.0.
How do I connect to my Kafka cluster?
Set the KAFKA_MCP_BOOTSTRAP_SERVERS environment variable or the --bootstrap-servers CLI flag.
Can I restrict the server to read-only?
Yes, use the --read-only flag to limit the server to read-only operations.
What is MultiplexTool?
A tool that batches multiple sequential tool calls into one request, with optional dynamic dependencies resolved via LLM prompts (currently Gemini requires GEMINI_API_KEY).
What authentication is supported?
The README does not mention authentication; it assumes a plain connection (e.g., to localhost:9092).
More Other MCP servers
🪟 Windows-MCP
CursorTouchMCP Server for Computer Use in Windows
AutoBrowser MCP
autobrowser-aiBrowser MCP is a Model Context Provider (MCP) server that allows AI applications to control your browser
Peekaboo MCP – lightning-fast macOS screenshots for AI agents
steipetePeekaboo is a macOS CLI & optional MCP server that enables AI agents to capture screenshots of applications, or the entire system, with optional visual question answering through local or remote AI models.
Website
FunnyWolfAdversary simulation and Red teaming platform with AI
EverArt
modelcontextprotocolModel Context Protocol Servers
Comments