mcp-confluent

Official
by confluentinc

create-flink-statement

Submit Flink SQL statements to process data streams in Confluent Cloud. Define statements with unique names, catalog, and database details for efficient execution within specified environments and compute pools.

Instructions

Make a request to create a statement.

Input Schema

NameRequiredDescriptionDefault
baseUrlNoThe base URL of the Flink REST API.
catalogNameYesThe catalog name to be used for the statement. Typically the confluent environment name.
computePoolIdNoThe id associated with the compute pool in context.
databaseNameYesThe database name to be used for the statement. Typically the Kafka cluster name.
environmentIdNoThe unique identifier for the environment.
organizationIdNoThe unique identifier for the organization.
statementYesThe raw Flink SQL text statement. Create table statements may not be necessary as topics in confluent cloud will be detected as created schemas. Make sure to show and describe tables before creating new ones.
statementNameYesThe user provided name of the resource, unique within this environment.

Input Schema (JSON Schema)

{ "$schema": "http://json-schema.org/draft-07/schema#", "additionalProperties": false, "properties": { "baseUrl": { "default": "", "description": "The base URL of the Flink REST API.", "format": "uri", "type": "string" }, "catalogName": { "default": "", "description": "The catalog name to be used for the statement. Typically the confluent environment name.", "minLength": 1, "type": "string" }, "computePoolId": { "description": "The id associated with the compute pool in context.", "type": "string" }, "databaseName": { "default": "", "description": "The database name to be used for the statement. Typically the Kafka cluster name.", "minLength": 1, "type": "string" }, "environmentId": { "description": "The unique identifier for the environment.", "type": "string" }, "organizationId": { "description": "The unique identifier for the organization.", "type": "string" }, "statement": { "description": "The raw Flink SQL text statement. Create table statements may not be necessary as topics in confluent cloud will be detected as created schemas. Make sure to show and describe tables before creating new ones.", "maxLength": 131072, "minLength": 1, "type": "string" }, "statementName": { "description": "The user provided name of the resource, unique within this environment.", "maxLength": 100, "minLength": 1, "pattern": "[a-z0-9]([-a-z0-9]*[a-z0-9])?(\\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*", "type": "string" } }, "required": [ "statement", "statementName", "catalogName", "databaseName" ], "type": "object" }
ID: 8zh4gg3sw9