为什么 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.