Kafka MCP Server

The Kafka MCP Server is a Model Context Protocol (MCP) server that provides integration with Apache Kafka to enable interaction with a Kafka cluster using natural language (LLMs).

demo

Prerequisites

You will either need Docker or Golang to run the MCP server locally.

Getting Started

You need to have access to a Kafka cluster. Following the quickstart doc:

 docker pull apache/kafka:4.0.0
 docker run -p 9092:9092 apache/kafka:4.0.0

Kafka is available on localhost:9092 now.

Usage with Claude Desktop

Docker:

{
  "mcpServers": {
    "kafka": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_MCP_BOOTSTRAP_SERVERS",
        "ghcr.io/cefboud/kafka-mcp-server"
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

Building locally

cd <workdir>
git clone https://github.com/CefBoud/kafka-mcp-server.git
cd kafka-mcp-server
go build -o kafka-mcp-server  cmd/kafka-mcp-server/main.go 

{
  "mcpServers": {
    "kafka": {
      "command": "<workdir>/kafka-mcp-server/kafka-mcp-server",
      "args": [
        "stdio"
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

Available MCP Tools

• List topics
• Create topic
• Consuming messages.
• Produce messages.
• List consumer groups and inspect lag.
• Reset consumer group offsets.
• Get topic's earliest and latest offsets (GetOffsetShell)
• Kafka Connect ??
• Schema Registry ??

Credits

• github.com/github/github-mcp-server
• github.com/mark3labs/mcp-go
• github.com/IBM/sarama