mcp-confluent

Official
by confluentinc

list-flink-statements

Retrieve and manage a sorted, filtered, and paginated list of Flink SQL statements using REST API, enabling precise control over statement queries and data.

Instructions

Retrieve a sorted, filtered, paginated list of all statements.

Input Schema

NameRequiredDescriptionDefault
baseUrlNoThe base URL of the Flink REST API.
computePoolIdNoFilter the results by exact match for compute_pool.
environmentIdNoThe unique identifier for the environment.
labelSelectorNoA comma-separated label selector to filter the statements.
organizationIdNoThe unique identifier for the organization.
pageSizeNoA pagination size for collection requests.
pageTokenNoAn opaque pagination token for collection requests.

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" }, "computePoolId": { "default": "", "description": "Filter the results by exact match for compute_pool.", "type": "string" }, "environmentId": { "description": "The unique identifier for the environment.", "type": "string" }, "labelSelector": { "description": "A comma-separated label selector to filter the statements.", "type": "string" }, "organizationId": { "description": "The unique identifier for the organization.", "type": "string" }, "pageSize": { "default": 10, "description": "A pagination size for collection requests.", "maximum": 100, "minimum": 0, "type": "integer" }, "pageToken": { "description": "An opaque pagination token for collection requests.", "maxLength": 255, "type": "string" } }, "type": "object" }
ID: 8zh4gg3sw9