What is kafka-mcp-enterprise?

A development guide for a Python reference server that lets coding agents interact with Apache Kafka through the Model Context Protocol, a standard way for tools and agents to communicate.

Use it when working on Kafka MCP, KIP-1318, tool calls, data-loss prevention checks, approval tokens, examples, tests, or PyPI packaging.

It brings together the project's test, security, example, and packaging procedures so work stays within what the reference server actually supports.

How vaquarkhan/kafka-mcp-enterprise-server configures Cursor

Reuse

Borrowing it

Nothing to install: this file belongs to vaquarkhan/kafka-mcp-enterprise-server. Take a copy, put it at the same path in your own repository, and replace the rules that are about this project with yours.

Copy the file

curl -O https://raw.githubusercontent.com/vaquarkhan/kafka-mcp-enterprise-server/main/.cursor/skills/kafka-mcp-enterprise/SKILL.md

Clone the repo

git clone --depth 1 https://github.com/vaquarkhan/kafka-mcp-enterprise-server

Made for: Cursor.

Wrote this? Show the measurements

A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.

README.md

[![agentmods](https://agentmods.dev/badge/skills/vaquarkhan/kafka-mcp-enterprise-server/kafka-mcp-enterprise/github.svg)](https://agentmods.dev/skills/vaquarkhan/kafka-mcp-enterprise-server/kafka-mcp-enterprise)

Your own site

<a href="https://agentmods.dev/skills/vaquarkhan/kafka-mcp-enterprise-server/kafka-mcp-enterprise"><img src="https://agentmods.dev/badge/skills/vaquarkhan/kafka-mcp-enterprise-server/kafka-mcp-enterprise/github.svg" alt="Measured on agentmods" height="20"></a>

Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.

Your own site · 80×15

<a href="https://agentmods.dev/skills/vaquarkhan/kafka-mcp-enterprise-server/kafka-mcp-enterprise"><img src="https://agentmods.dev/badge/skills/vaquarkhan/kafka-mcp-enterprise-server/kafka-mcp-enterprise.svg" alt="Reviewed on agentmods" width="80" height="20"></a>

Per session 82 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.

When invoked 538 The whole file, excluding the scripts and references it only reads on demand.

Security scan A 0 findings. A grade says what 26 rules found in the file — not that it is safe.

Origin original No closer match found in the catalogue.

Token cost

What it costs to keep this loaded

Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.

Model	Per session	Once invoked
Fable 5.1	$0.00082	$0.00538
Opus 5	$0.00041	$0.00269
Sonnet 5	$0.00016	$0.00108
Haiku 4.5	$0.00008	$0.00054

Measured 12d ago against content hash 2729f3ce8ad5, method: parsed. Prices are Anthropic first-party input rates as of 2026-09-12, from the pricing page.

Security

Grade A, and why

kafka-mcp-enterprise scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 12d ago.

A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.

Nothing flagged

None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.

.cursor/skills/kafka-mcp-enterprise/SKILL.md · 60 lines

What it actually says

Kafka MCP Enterprise - agent skill

Quick facts

Package: kafka-mcp-enterprise · CLI: kafka-mcp-enterprise · import: kafka_mcp
Official KIP/Jira: KIP-1318 / KAFKA-20436 (Java is production target)
This repo: Python stdlib reference + 302 conformance tests

Always do

Read AGENTS.md at repo root.
Prefer existing modules over new dependencies.
After code changes run: python run_tests.py (expect 302/302).
Optional: python run_coverage.py (expect 100% line coverage of kafka_mcp/).
Preserve honesty: taint best-effort; broker ACLs authoritative.
Do not claim HTTP / live brokers / EOS / Connect as implemented - see doc/kip-alignment.md.
Remember: this is a Python reference; production KIP work is Java (KAFKA-20436). Gaps belong there.

Common workflows

Validate

python run_tests.py
python demo_end_to_end.py
python examples/01_sre_readonly_triage/run.py

Call a tool in-process

from kafka_mcp.config import Config
from kafka_mcp.server import KafkaMcpServer

s = KafkaMcpServer(Config(tools_allowed=["*"], allowed_topic_prefixes=["agent."]))
print(s.handle({
  "jsonrpc":"2.0","id":1,"method":"tools/call",
  "params":{"name":"create_topic","arguments":{"name":"agent.demo"}}
}, {"identity":"agent"}))

Add an example

Create examples/0N_slug/{README.md,run.py,data/} and seed via examples._common.seed_topic_from_jsonl.

Security change checklist

Update evaluation order docs if stages change
Add/adjust tests under tests/test_security.py or test_guardrails.py
Document new codes in doc/error-codes.md

Changes

What this file has done since we first saw it

Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.

12d ago First seen · 60 lines · 82 tokens per session scan A 2729f3ce8ad5

Subscribe to this mod's changes

kafka-mcp-enterprise is a skill published in the GitHub repository vaquarkhan/kafka-mcp-enterprise-server (2 stars, last pushed 1mo ago), licensed Apache-2.0. It adds 82 tokens to every session and 538 once invoked, about $0.0004 per session on Opus 5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-31.

Backend and APIs Building agents aiagents apachekafka cybersecurity datastreaming enterprisearchitecture event-driven

eve

Build durable backend AI agents with the eve framework. Use when creating, editing, or debugging an eve project — agent instructions, skills, tools, connections, channels, sandboxes, subagents, schedules, or evals.

ComposioHQ/composio · 47 tokens

cross-sdk-parity

Keep TypeScript and Python SDK behavior, generated client usage, public API naming, and docs examples aligned. Use when a change affects both SDKs, when generated client pins move, when comparing TS/Python behavior, or when a backend API contract changed. Do not use for single-language internal-only changes.

ComposioHQ/composio · 66 tokens

python-sdk

Implement or modify Python SDK behavior under python/composio, including tools, toolkits, sessions, auth configs, connected accounts, client integration, and shared Python models. Use for Python core runtime/API work; pair with python-testing and cross-sdk-parity when TypeScript must match.

ComposioHQ/composio · 60 tokens

typescript-sdk

Implement or modify TypeScript SDK behavior in @composio/core or shared TypeScript packages, including tools, toolkits, sessions, auth configs, connected accounts, modifiers, and generated SDK surfaces. Use for TS runtime/API work; pair with typescript-testing for verification and cross-sdk-parity when Python must…

ComposioHQ/composio · 67 tokens

blind-sqli

Blind SQL injection under hostile WAF — manual bypass playbook for when sqlmap fails because common tokens (SUBSTRING, IF, AND, WHERE, single quotes) are filtered. Covers token-fingerprinting probe loops, arithmetic-multiplication boolean evaluation, hex-encoded literals, and exponential-probe binary search. Loaded on…

PurpleAILAB/Decepticon · 88 tokens

hpp

HTTP Parameter Pollution — parser discrepancies between proxy/server/app, WAF bypass, auth/ACL bypass, injection delivery.

PurpleAILAB/Decepticon · 25 tokens

kafka-mcp-enterprise-server: Skill for Cursor