Kafka Connect: worker故障时的错误检测

Question

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

使用状态接口call.Is处理这种情况的正确方法是什么?在触发此接口之前，是否需要使用任何延迟。或者可以在将连接器提交到API时进行处理？

Answer 1

在创建连接器时，它自然需要加载负责这些任务的JAR，然后分发任务以实际启动连接器代码(负责连接到SFTP服务器的连接细节)。

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