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.
The server publishes 5 tools. What each one is for:
Category — ToolsDocumentation — search-product-docs, get-product-doc-pageDiagnostics — explain-disabled-tools, list-configured-connections, config-help, describe-configured-connectionPrerequisites — The Prerequisites tool exposed by this serverSetup — The Setup tool exposed by this serverInstallation goes through your MCP client rather than a global install: point it at @confluentinc/mcp-confluent on npm and it is fetched when the client starts. The copy-paste blocks for Claude Desktop, Claude Code and Cursor are further down this page.
Configuration is passed through the environment: KAFKA_API_KEY, KAFKA_API_SECRET, SCHEMA_REGISTRY_API_KEY, SCHEMA_REGISTRY_API_SECRET. Treat anything key-shaped as a real credential — scope it to the minimum the server needs, and rotate it if it ever lands in a shared config.
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 |
A knowledge graph your assistant keeps between sessions — entities, relations and observations that persist.
Kill hallucinated APIs — version-accurate, up-to-date library documentation injected straight into context.
Your workspace, on speaking terms with AI — search, read and write Notion pages and databases.
A structured scratchpad for hard problems — stepwise reasoning with revisions, branches and visible logic.
Symbol-level code navigation, refactoring and memory for coding agents — the IDE brain your assistant has been missing.
Stop letting your assistant hallucinate n8n node parameters — this server hands it the real schemas, templates and validation.