使用连接器: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的用户写入。