kafka-mcp-server

from lehtinentimo

Expose Apache Kafka operations (topics, produce, consume, consumer groups) as MCP tools.

🔥🔥🔥🔥✓ VerifiedFreeAdvanced setup

Kafka MCP Server

A Model Context Protocol (MCP) server that exposes Apache Kafka operations as tools. Built with TypeScript, stdio transport, and the Confluent Kafka client.

Tools

Topics

Tool	Description	Inputs
`list-topics`	List all topics	none
`describe-topic`	Get topic details (partitions, replicas)	`topic`
`create-topic`	Create a new topic	`topic`, `numPartitions` (default 1), `replicationFactor` (default 1)
`delete-topic`	Delete a topic	`topic`

Produce / Consume

Tool	Description	Inputs
`produce`	Send a message to a topic	`topic`, `value`, `key` (optional)
`consume`	Read messages from a topic	`topic`, `maxMessages` (default 10), `timeout` (default 5000ms)

The consume tool creates an ephemeral consumer that reads from the earliest offset without committing. It disconnects after reaching maxMessages or the timeout.

Cluster

Tool	Description	Inputs
`get-cluster-info`	Get broker information	none
`list-consumer-groups`	List all consumer groups	none
`describe-consumer-group`	Get consumer group details	`groupId`

Development

npm run build          # Compile TypeScript
npm start              # Run the server
npm run lint           # Run ESLint
npm run lint:fix       # Run ESLint with auto-fix
npm run format         # Format code with Prettier
npm run format:check   # Check formatting

Copy & paste — that's it

npm install
npm run build

Before it works, you'll need: KAFKA_BROKERS

Prerequisites

Node.js 18.18+ or 20.9+
A running Kafka-compatible broker (Apache Kafka, Redpanda, etc.)

Setup

npm install
npm run build

Configuration

Set the KAFKA_BROKERS environment variable (required):

export KAFKA_BROKERS=localhost:9092

Multiple brokers can be comma-separated: broker1:9092,broker2:9092.

Running

npm start

The server communicates over stdio using the MCP protocol.

Claude Code

Add the MCP server using the CLI:

claude mcp add kafka-mcp-server -e KAFKA_BROKERS=localhost:9092 node /path/to/kafka-mcp-server/dist/index.js

Or add to .mcp.json in your project root:

{
  "mcpServers": {
    "kafka": {
      "command": "node",
      "args": ["/path/to/kafka-mcp-server/dist/index.js"],
      "env": {
        "KAFKA_BROKERS": "localhost:9092"
      }
    }
  }
}

Claude Desktop

Add to your Claude Desktop config (claude_desktop_config.json):

{
  "mcpServers": {
    "kafka": {
      "command": "node",
      "args": ["/path/to/kafka-mcp-server/dist/index.js"],
      "env": {
        "KAFKA_BROKERS": "localhost:9092"
      }
    }
  }
}