使用连接器: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
从源代码的Angular 来看,这是没有意义的,尤其是当您连接到您不控制的第三方源代码时。
1条答案
按热度按时间kx5bkwkv1#
您需要写权限,因为连接器会将它读取的文件移动到可配置的目录
finished.path
. 这场运动finished.path
在您提供的链接中解释:一旦文件被读取,它就会被放入配置好的finished.path目录中。
有关配置的文档
input.path
声明您需要对其进行写访问:input.path
-kafka connect读取已处理文件的目录。此目录必须存在并可由运行connect的用户写入。