如何解决为什么Kafka Connect Sftp源目录需要可写?
使用连接器: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
的过程:
读取文件后,会将其放置在已配置的finish.path目录中。
有关配置input.path
的文档指出您需要对其进行写访问:
input.path
-Kafka Connect读取已处理文件的目录。该目录必须存在,并且可以由运行Connect的用户写入。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。