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.
This server cannot be installed
Maintenance
Resources
Unclaimed servers have limited discoverability.
Looking for Admin?
If you are the server author, to access and configure the admin panel.
Related MCP Servers
- Alicense-qualityDmaintenanceEnables AI models to publish and consume messages from Apache Kafka topics through a standardized interface, making it easy to integrate Kafka messaging with LLM and agent applications.Last updated17Apache 2.0
- Flicense-qualityDmaintenanceEnables AI assistants to manage and monitor Apache Kafka clusters through natural language, providing real-time operations, health monitoring, consumer lag analysis, and temporal trend detection for intelligent cluster management.Last updated
- Alicense-qualityFmaintenanceEnables AI agents to interact with Apache Kafka through natural language, supporting operations like producing/consuming messages, managing topics, and querying brokers, partitions, and consumer group offsets.Last updated1MIT
- Alicense-qualityDmaintenanceEnables interaction with Kafka clusters via MCP, supporting topic management (list, create, delete, inspect), connection initialization, and more through natural language.Last updated1Apache 2.0
Related MCP Connectors
Connect your AI assistants to Keboola and expose your data, transformations, SQL queries, ...
Analytical memory for AI agents: a real Postgres queried in plain English over MCP. One command.
User-owned memory for AI agents, Copilot, Claude, IDEs, CLIs, and chat apps over remote MCP.
Latest Blog Posts
- Who's Calling? MCP Hosts Are an Identity Blind Spot (And the Spec Knows It)By Om-Shree-0709 on .mcpAgent IdentityOAuth 2.1
- Your AI Chatbot Just Exposed Your CEO's Salary to an InternBy Om-Shree-0709 on .Agent IdentityMCP SecurityOAuth Delegation
- Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)By Om-Shree-0709 on .Agentic AiPrompt InjectionWebAssembly
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