mcp-confluent

{ "$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" }, "environmentId": { "description": "The unique identifier for the environment.", "type": "string" }, "organizationId": { "description": "The unique identifier for the organization.", "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" }, "timeoutInMilliseconds": { "default": 60000, "description": "The function implements pagination. It will continue to fetch results using the next page token until either there are no more results or the timeout is reached. Tables backed by kafka topics can be thought of as never-ending streams as data could be continuously produced in near real-time. Therefore, if you wish to sample values from a stream, you may want to set a timeout. If you are reading a statement after creating it, you may need to retry a couple times to ensure that the statement is ready and receiving data.", "type": "number" } }, "required": [ "statementName" ], "type": "object" }