为什么Kafka Connect Sftp源目录需要可写



使用连接器:https://docs.confluent.io/current/connect/kafka-connect-sftp/source-connector/index.html

当我配置连接器并检查状态时,我会得到以下异常。。。

org.apache.kafka.connect.errors.ConnectException: Directory for 'input.path' '/FOO' it not writable.ntat io.confluent.connect.sftp.source.SftpDirectoryPermission.directoryWritable

从来源的角度来看,这是没有意义的,尤其是如果你正在连接到你不控制的第三方来源。

您需要写权限,因为连接器将将读取的文件移动到可配置的finished.path。这种进入finished.path的移动在您提供的链接中进行了解释:

读取文件后,会将其放入已配置的finished.path目录中。

配置input.path的文档说明您需要对其进行写访问:

input.path-Kafka Connect读取处理文件的目录。此目录必须存在,并且可由运行Connect的用户写入。

相关内容

  • 没有找到相关文章

最新更新