为什么 Kafka Connect Sftp 源目录需要可写?
Why does Kafka Connect Sftp source directory need to be writeable?
使用连接器: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.\n\tat io.confluent.connect.sftp.source.SftpDirectoryPermission.directoryWritable
从来源的角度来看,这没有任何意义,尤其是当您连接到您无法控制的第三方来源时。
您需要写入权限,因为连接器将移动它读取的文件到可配置的finished.path
。在您提供的 link 中解释了向 finished.path
的移动:
Once a file has been read, it is placed into the configured finished.path directory.
有关配置的文档 input.path
声明您需要对其进行写访问:
input.path
- The directory where Kafka Connect reads files that are processed. This directory must exist and be writable by the user running Connect.
使用连接器: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.\n\tat io.confluent.connect.sftp.source.SftpDirectoryPermission.directoryWritable
从来源的角度来看,这没有任何意义,尤其是当您连接到您无法控制的第三方来源时。
您需要写入权限,因为连接器将移动它读取的文件到可配置的finished.path
。在您提供的 link 中解释了向 finished.path
的移动:
Once a file has been read, it is placed into the configured finished.path directory.
有关配置的文档 input.path
声明您需要对其进行写访问:
input.path
- The directory where Kafka Connect reads files that are processed. This directory must exist and be writable by the user running Connect.