Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| CONFIG_PATH | Yes | File system path to store and retrieve conversation-based configurations for session persistence (Future Implementation) | |
| FLINK_ENV_ID | No | Unique identifier for the Flink environment, must start with 'env-' prefix | |
| FLINK_ORG_ID | No | Organization identifier within Confluent Cloud for Flink resource management | |
| KAFKA_ENV_ID | No | Environment identifier for Kafka cluster, must start with 'env-' prefix | |
| FLINK_API_KEY | Yes | Authentication key for accessing Confluent Cloud's Flink services, including compute pools and SQL statement management | |
| KAFKA_API_KEY | Yes | Authentication credential (username) required to establish secure connection with the Kafka cluster | |
| FLINK_ENV_NAME | No | Human-readable name for the Flink environment used for identification and display purposes | |
| FLINK_API_SECRET | Yes | Secret token paired with FLINK_API_KEY for authenticated access to Confluent Cloud's Flink services | |
| KAFKA_API_SECRET | Yes | Authentication credential (password) paired with KAFKA_API_KEY for secure Kafka cluster access | |
| KAFKA_CLUSTER_ID | No | Unique identifier for the Kafka cluster within Confluent Cloud ecosystem | |
| BOOTSTRAP_SERVERS | Yes | List of Kafka broker addresses in the format host1:port1,host2:port2 used to establish initial connection to the Kafka cluster | |
| FLINK_DATABASE_NAME | No | Name of the associated Kafka cluster used as a database reference in Flink SQL operations | |
| FLINK_REST_ENDPOINT | No | Base URL for Confluent Cloud's Flink REST API endpoints used for SQL statement and compute pool management | |
| KAFKA_REST_ENDPOINT | No | REST API endpoint for Kafka cluster management and administration | |
| FLINK_COMPUTE_POOL_ID | No | Unique identifier for the Flink compute pool, must start with 'lfcp-' prefix | |
| CONFLUENT_CLOUD_API_KEY | Yes | Master API key for Confluent Cloud platform administration, enabling management of resources across your organization | |
| SCHEMA_REGISTRY_API_KEY | Yes | Authentication key for accessing Schema Registry services to manage and validate data schemas | |
| SCHEMA_REGISTRY_ENDPOINT | No | URL endpoint for accessing Schema Registry services to manage data schemas | |
| CONFLUENT_CLOUD_API_SECRET | Yes | Master API secret paired with CONFLUENT_CLOUD_API_KEY for comprehensive Confluent Cloud platform administration | |
| SCHEMA_REGISTRY_API_SECRET | Yes | Authentication secret paired with SCHEMA_REGISTRY_API_KEY for secure Schema Registry access | |
| CONFLUENT_CLOUD_REST_ENDPOINT | No | Base URL for Confluent Cloud's REST API services |
Schema
Prompts
Interactive templates invoked by user choice
| Name | Description |
|---|---|
No prompts | |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| list-topics | List all topics in the Kafka cluster. |
| create-topics | Create new topic(s) in the Kafka cluster. |
| delete-topics | Delete the topic with the given names. |
| produce-message | Produce records to a Kafka topic. For saving user messages/history they should be saved to a kafka topic named claude-conversations unless otherwise specified. If the topic does not exist, it will be created via the create-topics tool. |
| list-flink-statements | Retrieve a sorted, filtered, paginated list of all statements. |
| create-flink-statement | Make a request to create a statement. |
| read-flink-statement | Make a request to read a statement and its results |
| delete-flink-statements | Make a request to delete a statement. |
| list-connectors | Retrieve a list of "names" of the active connectors. You can then make a read request for a specific connector by name. |
| read-connector | Get information about the connector. |
| create-connector | Create a new connector. Returns the new connector information if successful. |
| delete-connector | Delete an existing connector. Returns success message if deletion was successful. |
| 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 in Confluent Cloud. |
| list-tags | Retrieve all tags with definitions from Confluent Cloud Schema Registry. |
| alter-topic-config | Alter topic configuration in Confluent Cloud. |
| list-clusters | Get all clusters in the Confluent Cloud environment |
| list-environments | Get all environments in Confluent Cloud with pagination support |
| read-environment | Get details of a specific environment by ID |
| list-schemas | List all schemas in the Schema Registry. |