mcp-kafka

Name: mcp-kafka
Availability: InStock
Author: Athavan Kanapuli

mcp-kafka is a Model Context Protocol (MCP) server that allows AI assistants to interact directly with Apache Kafka. This tool simplifies the interaction with Kafka clusters, enabling AI assistants to create, manage, and operate Kafka topics and messages. It provides a seamless way to produce and consume messages, making it highly beneficial for developers and data engineers looking to integrate AI capabilities into their Kafka workflows.

GitHub

GitHub Stars

User Rating

Not Rated

Favorites

Views

Forks

Issues

Installation

Difficulty

Intermediate

Estimated Time

10-20 minutes

Requirements

Go 1.24 or higher

A running Kafka cluster (default connection: localhost:9092)

Installation

Prerequisites

Go: 1.24 or higher

Running Kafka Cluster: Default connection at localhost:9092

Installation Steps

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

4. Install as a Claude Desktop Tool

1Build the application as mentioned above.

2Place the executable in a location included in your system PATH or in a dedicated tools directory.

3Follow this [Claude Desktop Tool Installation Guide](https://modelcontextprotocol.io/quickstart/user) to install the tool.

Troubleshooting

Issue: Server won't start Solution: Check Go version and reinstall dependencies.

Configuration

Basic Configuration

Edit claude_desktop_config.json to add the MCP server:

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": {}
    }
  }
}

Advanced Configuration

Security Settings

Manage authentication credentials securely and use environment variables as needed.

Examples

Basic Usage

Programmatic Usage

javascript
// JavaScript example (Node.js)
const { MCPClient } = require('@modelcontextprotocol/client');

const client = new MCPClient();
await client.connect();

// Execute tool
const result = await client.callTool('toolName', {
  parameter1: 'value1',
  parameter2: 'value2'
});

console.log(result);