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 "Deploy 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 deployed
Maintenance
Related MCP Connectors
- toolsOAuthcom.streamkap
Streamkap CLI & MCP server - manage CDC pipelines, sources, destinations, and transforms
Interact with your Google Cloud Datastream resources using natural language commands.
- AgenTruxOAuthcom.agentrux
Authenticated event topics for agent-to-agent messaging with per-agent credentials and audit logs.
Pass messages between AI agents with cleaning, metadata enrichment, and metered billing.
Related MCP Servers
- AlicenseNot gradedqualityDmaintenanceEnables 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.17Apache 2.0
- FlicenseNot gradedqualityDmaintenanceEnables 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.-
- AlicenseNot gradedqualityBmaintenanceEnables 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.1MIT
- AlicenseNot gradedqualityDmaintenanceEnables interaction with Kafka clusters via MCP, supporting topic management (list, create, delete, inspect), connection initialization, and more through natural language.1Apache 2.0