fix: handle special character in S3 file name

Abhra Dasgupta · fhussonnois · commit 4fb68e34afc8 · 2023-03-23T14:27:06.000+01:00
diff --git a/connect-file-pulse-filesystems/filepulse-amazons3-fs/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/S3BucketKey.java b/connect-file-pulse-filesystems/filepulse-amazons3-fs/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/S3BucketKey.java
@@ -88,7 +88,8 @@ public String objectName() {
      * @return the {@link URI} for this Amazon S3 object.
      */
     public URI toURI() {
-        return URI.create("s3://" + bucketName + S3_FOLDER_SEPARATOR + key);
+        AmazonS3URI s3Uri = new AmazonS3URI("s3://" + bucketName + S3_FOLDER_SEPARATOR + key, true);
+        return s3Uri.getURI();
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,8 @@ public String objectName() {`
`88`	`88`	`* @return the {@link URI} for this Amazon S3 object.`
`89`	`89`	`*/`
`90`	`90`	`public URI toURI() {`
`91`		`- return URI.create("s3://" + bucketName + S3_FOLDER_SEPARATOR + key);`
	`91`	`+ AmazonS3URI s3Uri = new AmazonS3URI("s3://" + bucketName + S3_FOLDER_SEPARATOR + key, true);`
	`92`	`+ return s3Uri.getURI();`
`92`	`93`	`}`
`93`	`94`
`94`	`95`	`/**`