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.
[!TIP] Already a Confluent Cloud customer? Confluent offers a fully managed MCP server with no local server to run and no dependencies to install. It provides access to your Confluent Cloud resources with AI-powered connector diagnostics, governed by your existing RBAC permissions. Use this open-source server if you need Confluent Platform / self-managed Kafka support, or want to customize and extend the toolset.
Quick Start
Prerequisites: Node.js 22.19.0+. If you want to interact with Confluent Cloud, you need to create an account first.
- Generate a quick
config.yamlfile in your project root:
npx @confluentinc/mcp-confluent --init-config- Edit the
config.yamlfile with your connection details, then:
npx @confluentinc/mcp-confluent --config ./config.yamlSee Getting Started for full setup instructions and Configuring MCP Clients for integration with your preferred AI tool.
Table of Contents
- Quick Start
- Available Tools
- Using with Confluent Platform
- Getting Started
- Configuration
- OAuth Authentication for Confluent Cloud
- CLI Usage
- Configuring MCP Clients
- Telemetry
- Troubleshooting
- Contributing
Available Tools
Tools are auto-enabled based on which service blocks are present in your resolved configuration; see CONFIGURATION.md for the full block-to-tool mapping.
You can list all available tools via the CLI:
npx -y @confluentinc/mcp-confluent --list-toolsAlways-Available Tools
These tools need no service blocks or authentication — they're enabled even on a bare config, regardless of which deployment the rest of your config targets.
| Category | Tools | Description |
|---|---|---|
| Documentation | search-product-docs, get-product-doc-page | Search Confluent product docs and fetch full page content |
| Diagnostics | explain-disabled-tools, list-configured-connections, config-help, describe-configured-connection | Explain why tools are absent, list configured connections and the tools enabled on each, suggest the YAML to enable a specific tool, and describe one connection's config and tool availability |
Available Tools for Confluent Cloud
These tools require endpoints and authentication against specific Confluent Cloud components.
Refer to config.example.yaml for the full set of configuration variables.
Categories marked with ¹ also work with OAuth authentication — sign in via your browser instead of provisioning API keys.
| Category | Tools | Description |
|---|---|---|
| Kafka ¹ | list-topics, create-topics, delete-topics, produce-message, consume-messages, list-consumer-groups, describe-consumer-group, get-consumer-group-lag, alter-topic-config, get-topic-config | Manage topics, produce/consume messages, inspect consumer groups, configure topic settings |
| Flink SQL ¹ | create-flink-statement, list-flink-statements, get-flink-statement-results, delete-flink-statements, get-flink-statement-exceptions, list-compute-pools | Create and manage Flink SQL statements; discover Flink compute pools |
| Flink Catalog ¹ | list-flink-catalogs, list-flink-databases, list-flink-tables, describe-flink-table, get-flink-table-info | Explore Flink catalogs, databases, and table schemas |
| Flink Diagnostics ¹ | check-flink-statement-health, detect-flink-statement-issues, get-flink-statement-profile | Health checks, issue detection, and query profiling |
| Connectors ¹ | list-connectors, get-connector-config, get-connector-offsets, get-connector-status, get-connector-tasks, get-connector-error-summary, get-connector-error-recommendations, get-connector-logs, create-connector ², delete-connector, pause-connector, resume-connector, restart-connector, update-connector-config | Inspect and manage Kafka Connect connectors |
| Schema Registry ¹ | list-schemas, create-schema, delete-schema | List, inspect, create, and delete data schemas |
| Catalog & Tags ¹ | search-topics-by-tag, search-topics-by-name, create-topic-tags, delete-tag, remove-tag-from-entity, add-tags-to-topic, list-tags | Organize and search topics using tags |
| Organizations, Environments & Clusters ¹ | list-organizations, list-environments, read-environment, list-clusters | Discover Confluent Cloud resources |
| Tableflow ¹ | create-tableflow-topic, list-tableflow-topics, read-tableflow-topic, update-tableflow-topic, delete-tableflow-topic, list-tableflow-regions | Manage Tableflow-enabled topics |
| Tableflow Catalog ¹ | create-tableflow-catalog-integration, list-tableflow-catalog-integrations, read-tableflow-catalog-integration, update-tableflow-catalog-integration, delete-tableflow-catalog-integration | Manage Tableflow catalog integrations (e.g., AWS Glue) |
| Metrics ¹ | list-available-metrics, query-metrics | Discover and query Confluent Cloud operational metrics |
| Billing ¹ | list-billing-costs | Query billing and cost data |
¹ Also available under OAuth — see OAuth Authentication for Confluent Cloud for setup and caveats.
Categories not marked currently require a direct connection with static API keys; OAuth migration is in progress.
² Individual tool not available under OAuth; requires a direct connection with static API keys.
Available Tools for local deployments
These tools only require Kafka or Schema Registry endpoints - no Confluent Cloud API key/secret is needed. Ideal for local development with self-managed clusters, including Confluent Platform.
…