kafka-connect-fs

kafka-connect-fs copied to clipboard

auth failed when using password which contains special character in 'fs.uris'

1

example: username: root password: admin@123 fs.url: `sftp://root:admin%[email protected]` class: AbstractPolicy.java method: configFs(Map customConfigs) In this method, workingDir.toUri() wll change above uri to `sftp://root:admin%[email protected]`. After changing code like below, problem have solved....

lixwen

Hey, currently setting up the connector to read Parquet files from HDFS locally using docker compose. Can someone please verify that they have this reader (ParquetFileReader) working with the file_reader.batch_size...

DNewt