Skip to content
InfratoApp
InfratoApp / Resources / MCP servers / kafka-mcp-server

kafka-mcp-server

kafka-mcp-server is an MCP server. It reaches kafka. It needs KAFKA_SASL_PASSWORD to authenticate. Its repository has 57 GitHub stars; we last read it on 2026-10-24.

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

Install

MCP servers are packaged differently from each other -- some run via npx, some as a Docker image, some as a plain script you clone and run. kafka-mcp-server’s own README did not state one plainly enough for this page to quote it rather than guess, so it will not guess. The repository below states it.

What it reaches, and what it needs

Reaches
kafka
Credential
KAFKA_SASL_PASSWORD

Maintenance

Stars
57
State
listed
Licence
—
From the repository

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

What kafka-mcp-server can do

9 tools documented in its README. An AI client calls these by name.

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

Read from the README; names are kept only if the README contains them.

Common questions about kafka-mcp-server

What does kafka-mcp-server do?
This is a Model Context Protocol (MCP) server for Apache Kafka, implemented in Go and leveraging franz-go and mcp-go.
How do I install kafka-mcp-server?
Its README did not state an install command plainly enough for us to quote one, so we do not guess. The repository has the instructions: https://github.com/tuannvm/kafka-mcp-server
What does kafka-mcp-server connect to, and what does it need?
It reaches kafka. The credentials we found in its source are KAFKA_SASL_PASSWORD.
Is kafka-mcp-server official and is it maintained?
We found nothing naming it as a vendor’s official server. Its repository has 57 GitHub stars and its state in our directory is listed. Its last commit we recorded was on 2026-03-09.
What licence does kafka-mcp-server use?
The repository metadata we read does not state a licence, so check the repository before you rely on it.

Learn this on Infrato