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