MCP server for interacting with Confluent Cloud APIs, Kafka, Flink SQL, Schema Registry, connectors, and data catalog features
Add tags to a topic in the Confluent Cloud catalog
Alter the configuration of a topic
Consume messages from a Kafka topic
Create a new connector. Returns the new connector information if successful.
Make a request to create a statement.
Create a new TableFlow catalog integration
Create a new TableFlow topic
Create tags for a topic in the Confluent Cloud catalog
Create new topics in a Kafka cluster
Delete an existing connector. Returns success message if deletion was successful.
Delete a Flink SQL statement
Delete a TableFlow catalog integration
Delete a TableFlow topic
Delete a tag from the Confluent Cloud catalog
Delete topics from a Kafka cluster
Get the configuration of a topic
Get all clusters in the Confluent Cloud environment
Retrieve a list of "names" of the active connectors. You can then make a read request for a specific connector by name.
Get all environments in Confluent Cloud with pagination support
List all Flink SQL statements
List all schemas in the Schema Registry
List all TableFlow catalog integrations
List all available TableFlow regions
List all TableFlow topics
List all tags available in the Confluent Cloud catalog
List all topics in a Kafka cluster
Produce a message to a Kafka topic
Get information about the connector.
Get details of a specific environment by ID
Get details of a specific Flink statement
Get details of a specific TableFlow catalog integration
Get details of a specific TableFlow topic
Remove a tag from an entity in the Confluent Cloud catalog
Search for topics by name in the Confluent Cloud catalog
Search for topics by tag in the Confluent Cloud catalog
Update a TableFlow catalog integration
Update a TableFlow topic
| Scored | Grade | Overall | Spec posture | Rubric |
|---|---|---|---|---|
| 2026-09-22 | F | 0 | <=2025-11-25 | v2 |
| 2026-03-09 | F | 0 | 1.13.1 (from @modelcontextprotocol/sdk dependency)+ | v1 |