Kafka Connect：工作人员失败时的错误检测

Question

我正在向 kafka 提交连接器。创建的连接器是 sftp 连接器。现在，当密码错误时，连接器会在连接器失败时发回成功响应。密码错误当时没有给出回复。这是一个单一的场景，可能有多个这样的场景。现在，当我使用 <host>/connectors/<connector-name>/status 时，出现无法建立连接的错误消息。但是这个端点有一点延迟。如果我在创建连接器后立即尝试，我可能不会收到任何响应 (404)。

使用状态 api call.Is 处理此问题的正确方法是什么，在触发此 API 之前需要使用任何延迟。或者可以在提交连接器到API时处理吗？

Answer 1

创建连接器时，自然需要加载负责任务的 JAR，然后分发任务以实际启动连接器代码（负责使用连接详细信息连接到 SFTP 服务器） ).

因此，延迟是自然的，除非您在启动连接器之前尝试使用它们，否则无法知道您的连接详细信息是否正确。