restart_kafka_connector_task
Restart a specific Kafka connector task to resolve failures or performance issues within a defined environment and cluster.
Instructions
Restarts a specific task of a Kafka connector.
Args: environment: The environment name. cluster: The cluster name. connector: The connector name. task_id: The task ID to restart.
Returns: The result of the task restart operation.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| cluster | Yes | ||
| connector | Yes | ||
| task_id | Yes |
Implementation Reference
- The main handler function for the 'restart_kafka_connector_task' tool. It constructs an API endpoint to restart a specific task of a Kafka connector and makes a PUT request via api_client. The function is decorated with @mcp.tool(), which handles registration.async def restart_kafka_connector_task( environment: str, cluster: str, connector: str, task_id: int ) -> Dict[str, Any]: """ Restarts a specific task of a Kafka connector. Args: environment: The environment name. cluster: The cluster name. connector: The connector name. task_id: The task ID to restart. Returns: The result of the task restart operation. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/kafka-connect/clusters/{cluster}/connectors/{connector}/tasks/{task_id}/restart" return await api_client._make_request("PUT", endpoint)