A Claude Code plugin that lets developers build Confluent Cloud infrastructure and data streaming applications using natural language. Provides Claude Skills (slash commands) for managing environments, clusters, topics, and API keys — powered by MCP (Model Context Protocol).
This plugin provides a single MCP server (confluent-infra) with 15 tools covering full Confluent Cloud lifecycle management: infrastructure provisioning + data plane operations.
- Node.js 22+
- Claude Code CLI
- A Confluent Cloud account with an API key
Add these to your shell profile (~/.bashrc, ~/.zshrc, etc.):
export CONFLUENT_CLOUD_API_KEY=your-api-key
export CONFLUENT_CLOUD_API_SECRET=your-api-secretGenerate API keys at Confluent Cloud Settings > API Keys. Use a Cloud resource management API key (not a cluster-scoped key).
claude mcp add -s user confluent-infra \
-e CONFLUENT_CLOUD_API_KEY=${CONFLUENT_CLOUD_API_KEY} \
-e CONFLUENT_CLOUD_API_SECRET=${CONFLUENT_CLOUD_API_SECRET} \
-- npx -y @confluentinc/claude-code-confluent-plugin@latestThis registers the plugin globally so it's available in any directory.
npx @confluentinc/claude-code-confluent-plugin@latest install-commandsThis copies the plugin's slash commands to ~/.claude/commands/ so they're available globally.
claudeEnvironments:
/environments-create— Create a new Confluent Cloud environment/environments-list— List all environments/environments-update— Update environment name or governance package/environments-use— Set active environment for subsequent commands/environments-delete— Delete an environment
Clusters:
/clusters-create— Create a Kafka cluster (with provisioning wait + API key creation)/clusters-list— List clusters in an environment/clusters-delete— Delete a cluster
Topics:
/topics-create— Create a Kafka topic/topics-list— List topics in a cluster/topics-delete— Delete a topic
API Keys:
/api-keys-create— Create a cluster-scoped API key/api-keys-list— List API keys/api-keys-delete— Delete an API key
Setup:
/setup-streaming-app— Full end-to-end: environment → cluster → API key → topics → optional app scaffold
| Tool | Description |
|---|---|
create_environment |
Create a Confluent Cloud environment |
list_environments |
List all environments |
update_environment |
Update environment name or governance package |
delete_environment |
Delete an environment |
create_cluster |
Create a Kafka cluster (returns immediately, async provisioning) |
get_cluster |
Get cluster details and provisioning status |
list_clusters |
List clusters in an environment |
delete_cluster |
Delete a cluster |
create_api_key |
Create a cluster-scoped API key |
list_api_keys |
List API keys (optional resource filter) |
delete_api_key |
Delete an API key |
| Tool | Description |
|---|---|
create_topic |
Create a Kafka topic |
list_topics |
List all topics in a cluster |
delete_topic |
Delete a topic |
The claude mcp add command in Step 2 registers the MCP server in your user-level Claude Code settings (~/.claude.json), making it available from any directory.
# Install dependencies
npm install
# Build (cleans dist/ first)
npm run build
# Watch mode
npm run devConfluent Community License Agreement