Confluent MCP Server
Confluent MCP Server
An open-source MCP server that enables AI assistants to interact with Confluent Cloud, Confluent Platform, and standalone Apache Kafka deployments through natural language. It provides 50+ tools across Kafka, Flink SQL, Schema Registry, Connectors, Tableflow, and more -- usable from any MCP-compatible client including Claude Desktop, Claude Code, Cursor, VS Code, Goose, and Gemini CLI.
npx quick start above does not require it). On macOS the simplest install is Homebrew; npm works cross-platform: See pnpm's installation guide for other options. TheCompare MCP servers by category, or browse hosted MCP servers if you prefer an endpoint over a local process.
{
"mcpServers": {
"confluent": {
"command": "npx",
"args": ["-y", "@confluentinc/mcp-confluent"],
"env": {
"KAFKA_API_KEY": "your-value",
"KAFKA_API_SECRET": "your-value",
"SCHEMA_REGISTRY_API_KEY": "your-value",
"SCHEMA_REGISTRY_API_SECRET": "your-value"
}
}
}
}Add to claude_desktop_config.json, then restart Claude Desktop.
npx quick start above does not require it). On macOS the simplest install is Homebrew; npm works cross-platform: See pnpm's installation guide for other options. The| Variable | Description | Required |
|---|---|---|
| KAFKA_API_KEY | Credential the server authenticates with. | Yes |
| KAFKA_API_SECRET | Credential the server authenticates with. | Yes |
| SCHEMA_REGISTRY_API_KEY | Credential the server authenticates with. | Yes |
| SCHEMA_REGISTRY_API_SECRET | Credential the server authenticates with. | Yes |
Store entities, relations and observations in a local knowledge graph with the reference Memory MCP server.
A structured scratchpad for hard problems — stepwise reasoning with revisions, branches and visible logic.
Compile documents into a cited knowledge wiki. Retrieve evidence, query, and review via local MCP.
Recall past Claude Code conversations from any project as clean, compact Markdown.
A private, local research "second brain" for Claude — cited answers from your own library (it won't invent what it can't find), persistent project
Episodic memory and architectural policy for AI agents. Frames, Atlas, and Policy.