错误处理

Kafka Connect Error

此类错误发生在Sink Task执行数据导入前，例如使用Converter进行反序列化或者使用Kafka Transformations对消息记录进行轻量级修改时产生错误，您可以配置由Kafka提供的错误处理选项。

如果您想要跳过此类错误，请在Kafka Connect配置文件中配置属性errors.tolerance=all。

Tablestore Sink Task Error

此类错误发生在Sink Task执行数据导入时，例如解析消息记录或者写入Tablestore时产生错误，您可以配置由Tablestore Sink Connector提供的错误处理选项。

如果您想要跳过此类错误，请在connector配置文件中配置属性errors.tolerance=all。更多信息，请参见配置说明。同时，您还可以选择错误报告的方式，如果需要将产生错误的消息记录保存到Tablestore中独立的一张数据表中，请进行如下配置：

runtime.error.tolerance=all
runtime.error.mode=tablestore
runtime.error.table.name=error

在distributed模式下，您也可以通过REST API来管理connector和task。如果发生错误导致connector或者task停止，您可以选择手动重启connector或者task。

1. 检查connector和task状态。

   • 查看connector状态。

     curl http://localhost:8083/connectors/{name}/status

   • 查看task状态。

     curl http://localhost:8083/connectors/{name}/tasks/{taskid}/status

   其中http://localhost:8083/connectors为Kafka REST服务的地址，name必须与配置文件中的name（连接器名称）相同，taskid包含在connector状态信息中。

   您还可以通过执行以下命令获取taskid。

   curl http://localhost:8083/connectors/{name}/tasks

2. 手动重启connector或者task。

   • 重启connector。

     curl -X POST http://localhost:8083/connectors/{name}/restart

   • 重启task。

     curl -X POST http://localhost:8083/connectors/{name}/tasks/{taskId}/restart