Lenses MCP Server

Instructions

Implementation Reference

• src/lenses_mcp/tools/kafka_connectors.py:150-168 (handler)

  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)