kafka-connect-fs
kafka-connect-fs copied to clipboard
auth failed when using password which contains special character in 'fs.uris'
example:
username: root
password: admin@123
fs.url: sftp://root:admin%[email protected]
class: AbstractPolicy.java
method: configFs(Map<String, Object> customConfigs)
In this method, workingDir.toUri() wll change above uri to sftp://root:admin%[email protected]
.
After changing code like below, problem have solved.
FileSystem fs = FileSystem.newInstance(new URI(convert(uri)), fsConfig);
Could you submit a PR for this?