mcp-kafka

mcp-kafka is a Model Context Protocol (MCP) server that enables AI assistants to interact with Apache Kafka clusters. It acts as a bridge, allowing AI to create, manage, and interact with Kafka topics and messages.

Overview

This tool provides a set of Kafka operations accessible through AI assistants.

Features

Key features include:

• Topic Management: Create, list, delete, and describe Kafka topics.
• Message Handling: Produce messages to topics with keys and headers, and consume messages with configurable timeout.

Installation

Prerequisites

• Go 1.24+
• Running Kafka cluster (default: localhost:9092)

Building from Source

Build the application using make build. Optionally, build for a specific platform using make build GOOS=darwin GOARCH=arm64.

Installing as a Claude Desktop Tool

Follow the Claude Desktop Tool Installation Guide and configure claude_desktop_config.json with the provided JSON, adjusting the executable path and SASL credentials.

Configuration

Configure Kafka client using CLI flags such as --bootstrap-servers, --consumer-group-id, --username, and --password. SASL_PLAINTEXT and PLAINTEXT authentication are supported.

License

MIT License