A production-ready Model Context Protocol (MCP) server for Apache Kafka. Features Information Flow Control (IFC) sandboxing, granular namespace isolation, and strict bounded buffers to securely bridge autonomous AI agents with enterprise streaming infrastructure.
MCPpedia last refreshed this data
Kafka MCP Enterprise Server Kip 1318 is an MCP server that a production-ready Model Context Protocol (MCP) server for Apache Kafka. Features Information Flow Control (IFC) sandboxing, granular namespace isolation, and strict bounded buffers to securely bridge autonomous AI agents with enterprise streaming infrastructure. Its tool list has not been published yet over stdio, sse and http, requires no API key, and scores 84/100 on MCPpedia's security, maintenance and efficiency rubric.
Config is the same across clients — only the file and path differ.
{
"mcpServers": {
"kafka-mcp-enterprise-server-kip-1318": {
"args": [
"kafka-mcp-enterprise-kip1318"
],
"command": "uvx"
}
}
}Are you the author?
Add this badge to your README to show your security score and help users find safe servers.
Product packaging image for the PyPI package (not a web UI).
Run this in your terminal to verify the server starts. Then let us know if it worked — your result helps other developers.
uvx 'kafka-mcp-enterprise-kip1318' 2>&1 | head -1 && echo "✓ Server started successfully"
After testing, let us know if it worked:
Five weighted categories — click any category to see the underlying evidence.
No known CVEs.
Checked kafka-mcp-enterprise-kip1318 against OSV.dev.
Click any tool to inspect its schema.
Be the first to review
Have you used this server?
Share your experience — it helps other developers decide.
Sign in to write a review.
Others in data / ai-ml
MCP client bridge: connects to MCP servers and registers their tools on ctx.tools
An autonomous agent that conducts deep research on any data using any LLM providers
Manage Supabase projects — databases, auth, storage, and edge functions
The official MCP server implementation for the Perplexity API Platform
MCP Security Weekly
Get CVE alerts and security updates for Kafka Mcp Enterprise Server Kip 1318 and similar servers.
Start a conversation
Ask a question, share a tip, or report an issue.
Sign in to join the discussion.
Scope: This is a stdio, in-memory conformance reference for the KIP-1318 security control model. Real brokers, Streamable HTTP, OAuth 2.1, EOS/fencing, Connect tooling, distributed rate/breaker state, and durable audit topics are specified in the KIP (Java production track under KAFKA-20436) and are not implemented here. Full matrix: doc/kip-alignment.md.
| Area | This reference | KIP / Java track |
|---|---|---|
| Transport | stdio only | stdio + Streamable HTTP + OAuth |
| Backend | In-memory Kafka | Real Admin / Producer / Consumer |
| Tools | 13 registered | ~30+ (incl. Connect, EOS, group admin) |
| Resources | subset + Phase-1 lag/offsets | ~20 kafka:// URIs |
| Rate / quarantine | per-process | optional distributed backend |
| Audit | in-memory hash chain | durable audit topic |
| Default allow-list | read/consume only (SECURE_DEFAULT_TOOLS) | same secure-by-default posture |
| Conformance | 302/302 checks | KIP test plan |
| Site | https://vaquarkhan.github.io/kafka-mcp-enterprise-server/ |
| Source | site/ (index.html + local site/assets/site.css) |
| Deploy | .github/workflows/pages.yml publishes site/ on push to main |
pip install kafka-mcp-enterprise
echo {"jsonrpc":"2.0","id":1,"method":"tools/list"} | kafka-mcp-enterprise
| Package | kafka-mcp-enterprise |
| CLI | kafka-mcp-enterprise |
| Import | import kafka_mcp |
| Optional | pip install kafka-mcp-enterprise[otel] |
| Publish | Tag v* → .github/workflows/publish.yml (Trusted Publishing / OIDC - see doc/publishing.md) |
| AGENTS.md | AGENTS.md - canonical instructions for every coding agent |
| Skills | .cursor/skills/ (Cursor) · skills/ (portable) |
| Guide | doc/agents-and-skills.md - how to load in each IDE |
Python conformance reference for KIP-1318: a Model Context Protocol (MCP) control plane for agent access to Kafka. The KIP's production target is Java. This package validates the fail-closed security model over stdio against an in-memory backend - it is not a drop-in for the forthcoming first-party Java MCP server.
| KIP | KIP-1318: MCP Server for Apache Kafka |
| Jira | KAFKA-20436 - Implement KIP-1318 |
| Discuss | [DISCUSS] KIP-1318 on dev@kafka.apache.org |
| This repo | Stdlib Python reference / conformance server (teaching, demos, security validation) |
| KIP production target | Java module (tools/mcp-server) wrapping native Kafka client |