Skip to main content

Confluent

Official 🗄️ Data & Files

Official Confluent MCP for Apache Kafka and Confluent Cloud. Manage topics, produce/consume messages, run Flink SQL, manage schemas, connectors, and Tableflow through natural language with 51 tools.

Tags

Kafkaevent streamingFlink SQL

Tools (15)

list-topicscreate-topicsdelete-topicssearch-topics-by-nameproduce-messageconsume-messageslist-connectorscreate-connectorcreate-flink-statementlist-flink-statementslist-schemaslist-clusterslist-environmentslist-tableflow-topicscreate-tableflow-topic

Client configuration

Cursor (.cursor/mcp.json)

{ "mcpServers": { "confluent": { "command": "npx", "args": [ "-y", "@confluentinc/mcp-confluent@1.5.0" ], "env": { "CONFLUENT_CLOUD_API_KEY": "your-confluent-cloud-api-key-here", "CONFLUENT_CLOUD_API_SECRET": "your-confluent-cloud-api-secret-here", "BOOTSTRAP_SERVERS": "your-bootstrap-servers-here", "KAFKA_API_KEY": "your-kafka-api-key-here", "KAFKA_API_SECRET": "your-kafka-api-secret-here" } } } }

VS Code (.vscode/mcp.json)

{ "servers": { "confluent": { "command": "npx", "args": [ "-y", "@confluentinc/mcp-confluent@1.5.0" ], "env": { "CONFLUENT_CLOUD_API_KEY": "your-confluent-cloud-api-key-here", "CONFLUENT_CLOUD_API_SECRET": "your-confluent-cloud-api-secret-here", "BOOTSTRAP_SERVERS": "your-bootstrap-servers-here", "KAFKA_API_KEY": "your-kafka-api-key-here", "KAFKA_API_SECRET": "your-kafka-api-secret-here" }, "type": "stdio" } } }

Replace the placeholders before connecting. Authorize in your client when prompted.

The Cursor JSON also works in Claude Desktop's local MCP configuration. Install the required runtime and local software first.

Documentation →