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.
This server does not currently have a deployable release on Glama. Follow the repository's setup instructions to install and configure it for your MCP client, including any required credentials and local dependencies.
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
Build and manage data pipelines, add custom connectors, and chat with your data.
Streamkap CLI & MCP server - manage CDC pipelines, sources, destinations, and transforms
Interact with your Google Cloud Datastream resources using natural language commands.
Authenticated event topics for agent-to-agent messaging with per-agent credentials and audit logs.
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 gradedqualityDmaintenanceEnables 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