Best for
- AI assistants interacting with Confluent Cloud or Kafka
- Development environments using Confluent Platform or local Kafka
- Teams needing a unified toolset for Kafka, Flink, Schema Registry
C
Confluent MCP Server
Official
An open-source MCP server that enables AI assistants to interact with Confluent Cloud, Confluent Platform, and Apache Kafka through natural language.
GitHub source repository ↗
54FMRS · D
Confluent's official open-source MCP server, feature-rich covering Kafka, Flink, Schema Registry, etc., but configuration is complex and community support is limited.
Confluent MCP Server is an open-source server providing 50+ tools that cover Kafka, Flink SQL, Schema Registry, Connectors, Tableflow, and more, helping AI assistants manage Kafka clusters, run Flink SQL, and manage schemas and connectors. It works with Confluent Cloud, Confluent Platform, and local Kafka deployments. Compatible with multiple clients like Claude, Cursor, VS Code, and more.
Tools
search-product-docs
Search Confluent product documentation.
get-product-doc-page
Fetch the full markdown content of a Confluent product documentation page.
explain-disabled-tools
Explain why tools are missing or unavailable.
list-configured-connections
List every configured connection and the tools available on each.
config-help
Suggest configuration to enable a specific tool.
describe-configured-connection
Describe one connection's config and tool availability.
list-topics
List all topics in the Kafka cluster.
create-topics
Create one or more Kafka topics with optional partition count and replication factor.
delete-topics
Delete topics with the given names.
produce-message
Produce records to a Kafka topic, supporting Confluent Schema Registry serialization.
consume-messages
Consume messages from Kafka topics, optionally restricted to partition, offset, etc.
list-consumer-groups
List consumer groups on a Kafka cluster.
describe-consumer-group
Describe a single consumer group, returning state, type, protocol, etc.
get-consumer-group-lag
Compute live offset lag for a Kafka consumer group.
alter-topic-config
Alter topic configuration in Confluent Cloud.
get-topic-config
Retrieve configuration details for a Kafka topic.
get-partition-offsets
Return per-partition low/high watermarks and message counts for a topic.
create-flink-statement
Create a Flink SQL statement.
list-flink-statements
List Flink SQL statements.
get-flink-statement-results
Fetch result rows produced by a Flink SQL statement.
delete-flink-statements
Delete Flink SQL statements.
get-flink-statement-exceptions
Retrieve the most recent exceptions for a Flink SQL statement.
list-compute-pools
List Flink compute pools.
list-flink-catalogs
List catalogs available in the Flink environment.
list-flink-databases
List all databases (schemas) in a Flink catalog.
list-flink-tables
List all tables in a Flink database.
describe-flink-table
Get full schema details for a Flink table.
get-flink-table-info
Get table metadata via INFORMATION_SCHEMA.TABLES.
check-flink-statement-health
Perform an aggregate health check for a Flink SQL statement.
detect-flink-statement-issues
Detect issues for a Flink SQL statement.
get-flink-statement-profile
Get Query Profiler data for a Flink SQL statement.
list-connectors
List active connectors.
get-connector-config
Retrieve the full configuration map for a connector.
get-connector-offsets
Retrieve current offsets for a connector's tasks.
get-connector-status
Get the current state of a connector and its tasks.
get-connector-tasks
List the tasks of a connector along with their configurations.
get-connector-error-summary
Summarize a connector's current errors.
get-connector-error-recommendations
Get suggested remediation steps for a failed connector.
get-connector-logs
Retrieve recent log entries for a Confluent Cloud connector.
create-connector
Create a new connector.
delete-connector
Delete an existing connector.
pause-connector
Pause a running connector and its tasks.
resume-connector
Resume a paused connector and its tasks.
restart-connector
Restart a connector and its tasks.
update-connector-config
Update the configuration of an existing connector.
list-schemas
List all schemas in the Schema Registry.
create-schema
Register a new schema or a new version under a subject.
delete-schema
Delete a schema subject or a specific version from the Schema Registry.
search-topics-by-tag
List all topics in the Kafka cluster with the specified tag.
search-topics-by-name
List all topics in the Kafka cluster matching the specified name.
create-topic-tags
Create new tag definitions in Confluent Cloud.
delete-tag
Delete a tag definition from Confluent Cloud.
remove-tag-from-entity
Remove tag from an entity in Confluent Cloud.
add-tags-to-topic
Assign existing tags to Kafka topics.
list-tags
Retrieve all tags with definitions from Confluent Cloud Schema Registry.
list-organizations
List Confluent Cloud organizations the current credentials can see.
list-environments
Get all environments in Confluent Cloud.
read-environment
Get details of a specific environment by ID.
list-clusters
Get all clusters in the Confluent Cloud environment.
create-tableflow-topic
Create a Tableflow topic.
list-tableflow-topics
List Tableflow topics.
read-tableflow-topic
Read a Tableflow topic.
update-tableflow-topic
Update a Tableflow topic.
delete-tableflow-topic
Delete a Tableflow topic.
list-tableflow-regions
List Tableflow regions.
create-tableflow-catalog-integration
Create a catalog integration.
list-tableflow-catalog-integrations
List catalog integrations.
read-tableflow-catalog-integration
Read a catalog integration.
update-tableflow-catalog-integration
Update a catalog integration.
delete-tableflow-catalog-integration
Delete a catalog integration.
list-available-metrics
List available Confluent Cloud metrics.
query-metrics
Query Confluent Cloud metrics.
list-billing-costs
Query billing and cost data.
Setup
- Ensure Node.js 22.19.0 or later. 2. Generate a config file with
npx @confluentinc/mcp-confluent --init-config. 3. Edit the config.yaml file. 4. Start the server withnpx @confluentinc/mcp-confluent --config ./config.yaml. 5. Configure your MCP client to connect.
Fit and risk
Not for
- Kafka users outside the Confluent ecosystem (only subset of tools available)
- Users wanting a fully managed MCP server (consider Confluent's managed service)
- Users requiring dedicated support (community support is best-effort only)
Required permissions
- Access Kafka topics, consumer groups, and configurations
- Execute Flink SQL statements and read results
- Manage schemas in Schema Registry
- Manage connectors and Tableflow topics
- Read Confluent Cloud metrics and billing data
Risks and side effects
- Destructive operations (e.g., delete topics, delete schemas) must be authorized carefully
- OAuth credentials might be exposed if config files are not protected
- HTTP/SSE transports without API key may be vulnerable to unauthorized access
- Tableflow tools require cloud IAM permissions; misconfiguration may cause authorization errors
Troubleshooting
- Node.js version too low: upgrade to 22.19.0+
- Tools not appearing: run `--list-tools` to check enabled tools, or call `explain-disabled-tools`
- Authentication errors on HTTP/SSE: generate an API key with `--generate-key` and set it in `server.auth.api_key`
- Port conflicts: change `server.http.port` in config.yaml
- Tableflow authorization errors: follow the setup for IAM roles and policies
Use cases
Manage Kafka topics, consumer groups, and messages
Run Flink SQL queries and fetch results
Manage Schema Registry, connectors, and Tableflow
Query Confluent Cloud metrics and billing information
Supported clients
Claude DesktopFull support
Claude CodeFull support
CursorFull support
VS CodeFull support
GooseFull support
Gemini CLIFull support