delete_kafka_connector
Remove a Kafka connector from a specified environment and cluster to manage data integration workflows.
Instructions
Deletes a Kafka connector.
Args: environment: The environment name. cluster: The cluster name. connector: The connector name.
Returns: The result of the delete operation.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| cluster | Yes | ||
| connector | Yes |
Implementation Reference
- The async handler function decorated with @mcp.tool() that implements the delete_kafka_connector tool. It constructs the DELETE API endpoint and executes the request via api_client.@mcp.tool() async def delete_kafka_connector( environment: str, cluster: str, connector: str ) -> Dict[str, Any]: """ Deletes a Kafka connector. Args: environment: The environment name. cluster: The cluster name. connector: The connector name. Returns: The result of the delete operation. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}" return await api_client._make_request("DELETE", endpoint)
- src/lenses_mcp/server.py:29-29 (registration)Top-level registration call that invokes the module registration function, which registers the delete_kafka_connector tool among others.register_kafka_connectors(mcp)