Which integrations are available for this server?

Provides tools for managing Apache Kafka topics, messages, consumer groups, and cluster information with read/write access control and safety features.

How do I use MCP Kafka?

1. Click on "Deploy Server". 2. Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state. 3. In the chat, type @ followed by the MCP server name and your instructions, e.g., "@MCP Kafka list all topics in the cluster" That's it! The server will respond to your query, and you can continue using it as needed. Here is a step-by-step guide with screenshots.

MCP Kafka

by williajm

Overview Schema Source Related Servers Discussions Admin

Python

Remote

MCP Kafka

Category	Status
Build & CI
SonarCloud
Security
Technology

A Model Context Protocol (MCP) server for Apache Kafka that provides AI assistants with safe, controlled access to Kafka clusters.

Features

12 Kafka tools for topic management, message operations, consumer groups, and cluster info
2-tier access control: READ (default) and READ/WRITE modes
Universal Kafka support: SASL (PLAIN, SCRAM, GSSAPI) and mTLS authentication
Safety controls: Protected internal topics, consumer group validation, message size limits
Built with FastMCP: Modern MCP server implementation

Related MCP server: kafka-mcp

Installation

# Using uv (recommended)
uv add mcp-kafka

# Using pip
pip install mcp-kafka

Quick Start

1. Configure Environment

# Basic connection
export KAFKA_BOOTSTRAP_SERVERS=localhost:9092

# SASL authentication
export KAFKA_SECURITY_PROTOCOL=SASL_SSL
export KAFKA_SASL_MECHANISM=SCRAM-SHA-256
export KAFKA_SASL_USERNAME=your-username
export KAFKA_SASL_PASSWORD=your-password

# Enable write operations (disabled by default)
export SAFETY_ALLOW_WRITE_OPERATIONS=true

2. Run the Server

The server runs over local stdio only, for use behind a trusted MCP client.

uv run mcp-kafka

CLI Options

Option	Default	Description
`--health-check`	-	Run health check and exit
`--version`, `-v`	-	Show version and exit

3. Connect to MCP Client

Add to your MCP client configuration (e.g., Claude Desktop):

{
  "mcpServers": {
    "kafka": {
      "command": "uv",
      "args": ["run", "mcp-kafka"],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

Available Tools

Topic Management

Tool	Access	Description
`kafka_list_topics`	READ	List all topics with partition counts
`kafka_describe_topic`	READ	Get detailed topic info and configuration
`kafka_create_topic`	READ/WRITE	Create a new topic with partitions, replication factor, and config

Message Operations

Tool	Access	Description
`kafka_consume_messages`	READ	Peek at messages (no offset commit)
`kafka_produce_message`	READ/WRITE	Produce a message with optional key, headers, and partition

Consumer Group Management

Tool	Access	Description
`kafka_list_consumer_groups`	READ	List all consumer groups
`kafka_describe_consumer_group`	READ	Get group details, members, and lag
`kafka_get_consumer_lag`	READ	Get lag per partition
`kafka_reset_offsets`	READ/WRITE	Reset consumer group offsets to earliest, latest, or specific offset

Cluster Information

Tool	Access	Description
`kafka_cluster_info`	READ	Get cluster metadata
`kafka_list_brokers`	READ	List all brokers
`kafka_get_watermarks`	READ	Get topic partition watermarks

Configuration

For detailed configuration options and examples, see CONFIGURATION.md.

Environment Variables

Kafka Connection

Variable	Default	Description
`KAFKA_BOOTSTRAP_SERVERS`	`localhost:9092`	Kafka broker addresses
`KAFKA_SECURITY_PROTOCOL`	`PLAINTEXT`	Security protocol (PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL)
`KAFKA_CLIENT_ID`	`mcp-kafka`	Client identifier
`KAFKA_TIMEOUT`	`30`	Operation timeout in seconds

SASL Authentication

Variable	Default	Description
`KAFKA_SASL_MECHANISM`	-	SASL mechanism (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, GSSAPI)
`KAFKA_SASL_USERNAME`	-	SASL username
`KAFKA_SASL_PASSWORD`	-	SASL password
`KAFKA_SASL_KERBEROS_SERVICE_NAME`	`kafka`	Kerberos service name
`KAFKA_SASL_KERBEROS_KEYTAB`	-	Path to Kerberos keytab
`KAFKA_SASL_KERBEROS_PRINCIPAL`	-	Kerberos principal

SSL/TLS

Variable	Default	Description
`KAFKA_SSL_CA_LOCATION`	-	CA certificate path
`KAFKA_SSL_CERTIFICATE_LOCATION`	-	Client certificate path
`KAFKA_SSL_KEY_LOCATION`	-	Client key path
`KAFKA_SSL_KEY_PASSWORD`	-	Client key password

Safety Controls

Variable	Default	Description
`SAFETY_ALLOW_WRITE_OPERATIONS`	`false`	Enable READ/WRITE tools
`SAFETY_MAX_MESSAGE_SIZE`	`1048576`	Max message size in bytes (1MB)
`SAFETY_MAX_CONSUME_MESSAGES`	`100`	Max messages per consume request
`SAFETY_TOPIC_BLOCKLIST`	-	Comma-separated blocked topic patterns

Access Control

MCP Kafka uses a simple 2-tier access control system:

READ Access (Default)

List topics, consumer groups, and brokers
Describe topics and consumer groups
Consume messages (read-only peek)
Get cluster info and watermarks

READ/WRITE Access

Requires SAFETY_ALLOW_WRITE_OPERATIONS=true:

Create topics
Produce messages
Reset consumer group offsets

Protected Resources

The following resources are always protected:

Internal topics: __consumer_offsets, __transaction_state
Internal consumer groups: Groups starting with __
Topics in blocklist: Configured via SAFETY_TOPIC_BLOCKLIST

Development

Prerequisites

Python 3.11+
uv package manager

Setup

# Clone repository
git clone https://github.com/williajm/mcp_kafka.git
cd mcp_kafka

# Install dependencies
uv sync --all-extras

# Run tests
uv run pytest

# Run linting
uv run ruff check src/ tests/
uv run ruff format --check src/ tests/

# Run type checking
uv run mypy src/

Local Kafka for Testing

A Docker Compose environment is provided for local development:

# Start Kafka
docker compose -f docker/docker-compose.yml up -d

# Create test topics
docker compose -f docker/docker-compose.yml exec kafka \
  kafka-topics --create --topic test-topic --partitions 3 --replication-factor 1 \
  --bootstrap-server localhost:9092

# Stop Kafka
docker compose -f docker/docker-compose.yml down

License

MIT License - see LICENSE file for details.

This server cannot be deployed

One endpoint for every MCP toolRayrun runs every MCP server behind one URL and holds the credentials. Each call is decided per client, tool, and argument, then recorded.ray.runAd

Maintenance

ActivityMaintained

ResponsivenessSyncing

Resources

GitHub Repository

Need Help?

Related Servers

Related MCP Connectors

anotherai
dev.anotherai
MCP server for building and testing AI agents with multi-model experimentation and insights.
Agent Orchestration Autonomous Agents Testing & QA Tools
2
OneSchema MCP Server
co.oneschema
MCP server that lets AI assistants use all OneSchema features exposed via the public API.
Data Platforms App Automation
1
secureflows-mcp A
io.github.michal-lefler
MCP server for secureFlows: token-free URL builders and integration-linting tools for AI agents.
Code Analysis Developer Tools Security
181
gainium-mcpOAuth
io.gainium
MCP server for Gainium — manage trading bots, deals, and balances via AI assistants
Cryptocurrency Finance
22

Related MCP Servers

Kafka MCP Server
Databases Monitoring Data Platforms
jilanisayyad
A
license
Not graded
quality
D
maintenance
An MCP server that enables interaction with Kafka clusters to manage topics, monitor consumer groups, and stream messages. It provides a comprehensive suite of tools for broker metadata inspection and local Kafka user management.
Updated 7 months ago (2026-02-16 15:40 UTC)
MIT
kafka-mcp
Databases Developer Tools Monitoring
wklee610
A
license
B
quality
B
maintenance
MCP server for Apache Kafka that allows LLM agents to inspect topics, consumer groups, and safely manage offsets (reset, rewind).
Updated a month ago (2026-08-23 04:59 UTC)
19
13
Apache 2.0
Kafka MCP Server
Data Platforms Monitoring Developer Tools
aswinayyolath
F
license
Not graded
quality
D
maintenance
A comprehensive MCP server for Apache Kafka operations, enabling seamless integration with Claude Desktop and other MCP clients for cluster management, topic operations, and message streaming.
Updated a year ago (2025-08-04 12:49 UTC)
2
-
kafka-mcp
Data Platforms Developer Tools
zakariahere
F
license
C
quality
D
maintenance
Exposes Kafka administration operations as MCP tools, enabling AI agents to inspect Kafka clusters using natural language.
Updated 3 months ago (2026-06-13 15:10 UTC)
1
-

MCP Kafka

Features

Installation

Quick Start

1. Configure Environment

2. Run the Server

CLI Options

3. Connect to MCP Client

Available Tools

Topic Management

Message Operations

Consumer Group Management

Cluster Information

Configuration

Environment Variables

Kafka Connection

SASL Authentication

SSL/TLS

Safety Controls

Access Control

READ Access (Default)

READ/WRITE Access

Protected Resources

Development

Prerequisites

Setup

Local Kafka for Testing

License

Maintenance

Resources

Related MCP Connectors

Related MCP Servers

Kafka MCP Server

kafka-mcp

Kafka MCP Server

kafka-mcp