kafka-mcp-server MCP Server

A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.

Local serverstdio

What is the kafka-mcp-server MCP Server?

kafka-mcp-server is an MCP project maintained in the tuannvm/kafka-mcp-server repository. The maintainer describes its purpose as “A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go”. Read the project documentation for the complete scope.

Local setup

The project provides a local client configuration using kafka-mcp-server. 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, KAFKA_CLIENT_ID, MCP_TRANSPORT. 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.

Tool	What it does
produce_message	Produces messages to Kafka topics
consume_messages	Consumes messages from Kafka topics in batch operations
list_brokers	Lists all configured Kafka broker addresses
describe_topic	Provides comprehensive metadata for specific topics
list_consumer_groups	Enumerates all consumer groups in the cluster
describe_consumer_group	Provides detailed consumer group information including lag metrics
describe_configs	Retrieves configuration settings for Kafka resources
cluster_overview	Provides comprehensive cluster health summaries
list_topics	Lists all topics with metadata including partition and replication information

How to install the kafka-mcp-server MCP Server

{
  "mcpServers": {
    "kafka": {
      "command": "kafka-mcp-server",
      "args": [],
      "env": {
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "kafka-mcp-server",
        "MCP_TRANSPORT": "stdio"
      }
    }
  }
}

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

Configuration

Variable	Description	Required
KAFKA_BROKERS	Declared in the maintainer’s client configuration.	Check documentation
KAFKA_CLIENT_ID	Declared in the maintainer’s client configuration.	Check documentation
MCP_TRANSPORT	Declared in the maintainer’s client configuration.	Check documentation