Kafka MCP 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.
Click on "Install Server".
Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state.
In the chat, type
@followed by the MCP server name and your instructions, e.g., "@Kafka MCP Serverpublish a test message to the orders topic"
That's it! The server will respond to your query, and you can continue using it as needed.
Here is a step-by-step guide with screenshots.
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.jsonOn 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.
Latest Blog Posts
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/DevarshKumbhare/MCP-Kafka'
If you have feedback or need assistance with the MCP directory API, please join our Discord server