Discover the toolingbehind modern intelligence
The operating system for AI infrastructure discovery. Search a live map of MCP servers, AI agents, LLM tools, automation systems, and developer infrastructure.
mcp-kafka
mcp server for Apache Kafka, Schema Registry and Apache Flink
13stars
3forks
Java
Quality signals
ActiveNo testsNo CIThin docsNo licenseNew
AI summary
Auto-generated overview of what this skill does and when to reach for it.
MCP server that lets AI assistants interact with Apache Kafka, Schema Registry, and Flink SQL Gateway via 22 tools.
Use this when
- Debugging Kafka topic issues in real time
- Checking consumer lag or under-replicated partitions
- Registering or updating Avro schemas in Schema Registry
- Running Flink SQL queries against a cluster
- Generating cluster health reports for documentation
Don't use when
- Need to modify Kafka brokers directly
- Working with Confluent Cloud exclusively
- Require GUI-based Kafka management
Capabilities
- 22 MCP tools for Kafka topic management
- Produce/consume messages with Avro serialization
- Schema Registry CRUD operations (register, list, get, delete)
- Flink SQL Gateway query execution
- Topic search and cluster overview
- Consumer lag and under-replicated partition checks
Install
Universal installANY TOOL
$ npx skillcity@latest gAmUssA/mcp-kafkaAuto-detects the skill or MCP server in this repo and installs it for Claude Code, Codex, Cursor, Cline, OpenCode, Gemini CLI, Anti-Gravity, OpenClaw and Hermes.
Requires Node.js 18+ (ships with npx).
Prefer to set it up by hand? Clone the repository:
git clone https://github.com/gAmUssA/mcp-kafka.git
Loading README…
Ask a simulated agent to run this skill. It loads the real SKILL.md and reasons over your task with NVIDIA.
mcp-kafka — sandboxAI sandbox
Pick a quick prompt below or type your own — watch the agent execute this skill step by step.
guest@skillcity:~$Try a prompt