kafka-mcp-server 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.

Local serverstdioMIT

What is the kafka-mcp-server MCP Server?

kafka-mcp-server is an MCP project maintained in the lehtinentimo/kafka-mcp-server repository. The maintainer describes its purpose as “A Model Context Protocol (MCP) server that exposes Apache Kafka operations as tools. Built with TypeScript, stdio transport, and the Confluent Kafka client”. Read the project documentation for the complete scope.

Local setup

The project provides a local client configuration using node. Follow the repository’s build and installation steps before copying it, and replace example paths with the paths on your own computer.

Configuration values

The example declares KAFKA_BROKERS. Secret-looking values have been replaced with placeholders. Required and optional labels are shown only when the documentation states them.

Source

Project documentation · Repository · Discovery listing. This profile records the public documentation checked on 2026-10-08.

Recorded tools

Check the linked publisher documentation and your connected client's tool list. Names and availability can vary with the server version and account permissions.

ToolWhat it does
list-topicsList all topics
describe-topicGet topic details (partitions, replicas)
create-topicCreate a new topic
delete-topicDelete a topic
produceSend a message to a topic
consumeRead messages from a topic
get-cluster-infoGet broker information
list-consumer-groupsList all consumer groups
describe-consumer-groupGet consumer group details

How to install the kafka-mcp-server MCP Server

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

From the project documentation. Replace placeholders and example paths before connecting.

Configuration

VariableDescriptionRequired
KAFKA_BROKERSDeclared in the maintainer’s client configuration.Yes