fix(filesystems): fix regression on AmazonS3Client configuration (#184)

fhussonnois · fhussonnois · commit 7bdc78790d9f · 2021-09-26T18:59:49.000+02:00
Resolves: #184
diff --git a/connect-file-pulse-filesystems/filepulse-amazons3-fs/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/AmazonS3ClientUtils.java b/connect-file-pulse-filesystems/filepulse-amazons3-fs/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/AmazonS3ClientUtils.java
@@ -72,9 +72,9 @@ public static AmazonS3 createS3Client(final AmazonS3ClientConfig config,
         final String region = config.getAwsS3Region();
         final String endpoint = Optional.ofNullable(url).orElse(config.getAwsS3ServiceEndpoint());
         if (isNotBlank(endpoint)) {
-            builder = builder.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(url, region));
+            builder = builder.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, region));
         } else {
-            builder.withRegion(region);
+            builder = builder.withRegion(region);
         }
         return builder.build();
     }

Original file line number	Diff line number	Diff line change
`@@ -72,9 +72,9 @@ public static AmazonS3 createS3Client(final AmazonS3ClientConfig config,`
`72`	`72`	`final String region = config.getAwsS3Region();`
`73`	`73`	`final String endpoint = Optional.ofNullable(url).orElse(config.getAwsS3ServiceEndpoint());`
`74`	`74`	`if (isNotBlank(endpoint)) {`
`75`		`- builder = builder.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(url, region));`
	`75`	`+ builder = builder.withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, region));`
`76`	`76`	`} else {`
`77`		`- builder.withRegion(region);`
	`77`	`+ builder = builder.withRegion(region);`
`78`	`78`	`}`
`79`	`79`	`return builder.build();`
`80`	`80`	`}`