Confluent (npx) MCP Server
CommunityContributed by Confluent
Manage Confluent Cloud and Kafka resources. Create topics, produce and consume messages, run Flink SQL queries, and manage schemas.
About the Confluent (npx) MCP Server
The Confluent (npx) MCP server is a local (stdio) Model Context Protocol server available in the McpMux registry. Manage Confluent Cloud and Kafka resources. Create topics, produce and consume messages, run Flink SQL queries, and manage schemas. This is a community-contributed MCP server by Confluent.
Install the Confluent (npx) MCP server with one click using McpMux. It works with Cursor, Claude Desktop, Claude Code, VS Code, ChatGPT, Windsurf, JetBrains, and any MCP-compatible AI client. This server requires an API key — McpMux securely stores your credentials with AES-256-GCM encryption.
Transport Configuration
{
"type": "stdio",
"command": "npx",
"args": [
"-y",
"@confluentinc/mcp-confluent"
],
"env": {
"CONFLUENT_CLOUD_API_KEY": "${input:CONFLUENT_CLOUD_API_KEY}",
"CONFLUENT_CLOUD_API_SECRET": "${input:CONFLUENT_CLOUD_API_SECRET}",
"BOOTSTRAP_SERVERS": "${input:BOOTSTRAP_SERVERS}",
"KAFKA_API_KEY": "${input:KAFKA_API_KEY}",
"KAFKA_API_SECRET": "${input:KAFKA_API_SECRET}"
},
"metadata": {
"inputs": [
{
"id": "CONFLUENT_CLOUD_API_KEY",
"label": "Confluent Cloud API Key",
"description": "Cloud API key for Confluent Cloud resource management.",
"type": "text",
"required": true,
"secret": true,
"placeholder": "XXXXXXXXXXXXXXXX",
"obtain": {
"url": "https://confluent.cloud/settings/api-keys",
"instructions": "1. Go to confluent.cloud > Settings > API Keys\n2. Click 'Create Key'\n3. Select 'Cloud resource management'\n4. Copy the key and secret",
"button_label": "Create API Key"
}
},
{
"id": "CONFLUENT_CLOUD_API_SECRET",
"label": "Confluent Cloud API Secret",
"description": "Cloud API secret paired with the Cloud API key.",
"type": "text",
"required": true,
"secret": true,
"placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
},
{
"id": "BOOTSTRAP_SERVERS",
"label": "Kafka Bootstrap Servers",
"description": "Kafka bootstrap server address for your Confluent Cloud cluster.",
"type": "text",
"required": true,
"secret": false,
"placeholder": "pkc-xxxxx.us-east-1.aws.confluent.cloud:9092"
},
{
"id": "KAFKA_API_KEY",
"label": "Kafka Cluster API Key",
"description": "API key specific to your Kafka cluster.",
"type": "text",
"required": true,
"secret": true,
"placeholder": "XXXXXXXXXXXXXXXX"
},
{
"id": "KAFKA_API_SECRET",
"label": "Kafka Cluster API Secret",
"description": "API secret paired with the Kafka cluster API key.",
"type": "text",
"required": true,
"secret": true,
"placeholder": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
}
]
}
}Supported AI Clients
The Confluent (npx) MCP server works with all MCP-compatible AI clients through McpMux:
Related MCP Servers
Vercel
Access Vercel project deployments, runtime logs, and configuration through Vercel's official hosted remote MCP server with OAuth. Currently read-only.
Cloudflare Docs
Search Cloudflare developer documentation using semantic search. Covers Workers, Pages, R2, D1, KV, Durable Objects, Zero Trust, and all Cloudflare products.
Cloudflare Workers Bindings
Manage Cloudflare Workers platform resources including KV namespaces, R2 buckets, D1 databases, Hyperdrive configs, and Workers scripts.
Supabase (Remote)
Manage Supabase projects, databases, edge functions, storage, and authentication through Supabase's hosted remote MCP server. Authenticates via OAuth, no local setup required.
Supabase (npx)
Manage Supabase projects, databases, edge functions, storage, and authentication locally via npx. Uses a personal access token.
Docker Hub (Docker)
Search Docker Hub images, manage repositories and tags, discover Docker Hardened Images, and get AI-powered image recommendations. Interfaces with Docker Hub APIs for intelligent content discovery.
Install Confluent (npx) with McpMux
One-click install from the McpMux desktop app. Auto-configures for Cursor, Claude, VS Code, ChatGPT, Windsurf, JetBrains, and any MCP-compatible client.