kanapuli/mcp-kafka

A Model Context Protocol (MCP) server for performing Kafka client operations from AI assistants.
## Overview
mcp-kafka provides a bridge between AI assistants and Apache Kafka, allowing them to interact with Kafka clusters through the Model Context Protocol. This tool enables AI assistants to create, manage, and interact with Kafka topics and messages directly.
Here is a short video demo on youtube
## Features
The mcp-kafka server provides the following Kafka operations:
Create Topic: Create a new Kafka topic with configurable partitions and replication factor
List Topics: Get a list of all available Kafka topics in the cluster
Delete Topic: Remove an existing Kafka topic
Describe Topic: Get detailed information about a specific topic, including partition details
Produce Message: Send messages to a Kafka topic with support for message keys and headers
Consume Messages: Read messages from a Kafka topic with configurable timeout
## Installation
### Prerequisites
Go 1.24 or higher
A running Kafka cluster (default connection: localhost:9092)
### Building from Source
1. Clone the repository:
bash
git clone https://github.com/kanapuli/mcp-kafka.git
cd mcp-kafka
2. Build the application:
bash
make build
3. Optionally, build for a specific platform:
bash
make build GOOS=darwin GOARCH=arm64
### Installing as a Claude Desktop Tool
To use mcp-kafka with Claude Desktop:
1. Build the application as mentioned above.
2. Place the executable in a location included in your system PATH or in a dedicated tools directory.
3. Please follow this Claude Desktop Tool Installation Guide to install the tool.
The JSON to be added to the claudedesktopconfig.json file is as follows,
Use the right username and password for SASL login. Leave them empty for PLAINTEXT authentication.
json
"mcpServers": {
"kafka": {
"command": "/Your-mcp-kafka-executable-path/mcp-kafka-darwin-arm64",
"args": [
"--bootstrap-servers=localhost:9092",
"--consumer-group-id=mcp-kafka-consumer-group",
"--username=",
"--password="
],
"env": {}
## Configuration
The mcp-kafka tool accepts the following configuration parameters:
| Parameter | Description | Default |
| topic | Topic to interact with | (required) |
| numpartitions | Number of partitions for topic creation | (optional) |
| replicationfactor | Replication factor for topic creation | (optional) |
| producemessagekey | Key for produced messages | (optional) |
| producemessagevalue | Value for produced messages | (optional) |
| producemessageheaders | Headers for produced messages | (optional) |