Kafka MCP Server
A Model Context Protocol server implementation for Apache Kafka. Enabling MCP client to interact with topics hosted in a Kafka instance.
Running locally with the Claude desktop app
Manual Installation
- Clone this repository.
- Add the following to your
claude_desktop_config.jsonfile:
- On MacOS:
~/Library/Application\ Support/Claude/claude_desktop_config.json - On Windows:
%APPDATA%/Claude/claude_desktop_config.json
{
"mcpServers": {
"kafka": {
"command": "uv",
"args": [
"--directory",
"/path/to/repo/mcp-kafka",
"run",
"mcp-server-kafka",
"--kafka-bootstrap-servers",
"<comma_separated_bootstrap_servers ex. localhost:9092,otherhost:9092>",
# Add other Kafka connection arguments as needed (e.g., security protocol, SASL mechanism, username, password)
# Example for SASL_SSL:
# "--kafka-security-protocol", "SASL_SSL",
# "--kafka-sasl-mechanism", "PLAIN",
# "--kafka-sasl-plain-username", "<your_username>",
# "--kafka-sasl-plain-password", "<your_password>"
]
}
}
}
- Install and open the Claude desktop app.
- Try asking Claude to do a read/write operation of some sort to confirm the setup (e.g. ask it to publish a message to a topic or read messages from a topic). If there are issues, use the Debugging tools provided in the MCP documentation here.