-
Notifications
You must be signed in to change notification settings - Fork 29
S3 Sink update aws sdk to 2.X #572
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
Signed-off-by: Aindriu Lavelle <[email protected]>
| .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials( | ||
| localStackContainer.getAccessKey(), localStackContainer.getSecretKey()))) | ||
| static S3Client createS3Client(final LocalStackContainer localStackContainer) { | ||
| return S3Client.builder() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove the use of the aws sdk 1.X client for integration tests.
| } | ||
|
|
||
| private AmazonS3 createAmazonS3Client(final S3SinkConfig config) { | ||
| final var awsEndpointConfig = newEndpointConfiguration(this.config); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is now in S3ClientFactory
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This has been copied from the S3Source connector, I should just move this to a common place.
s3-sink-connector/src/test/java/io/aiven/kafka/connect/s3/testutils/BucketAccessor.java
Outdated
Show resolved
Hide resolved
s3-sink-connector/src/main/java/io/aiven/kafka/connect/s3/config/S3SinkConfig.java
Outdated
Show resolved
Hide resolved
s3-sink-connector/src/test/java/io/aiven/kafka/connect/s3/S3OutputStreamTest.java
Outdated
Show resolved
Hide resolved
…sting the correct details Signed-off-by: Aindriu Lavelle <[email protected]>
d49ef0e to
d192572
Compare
This is a small change made to be able to remove the aws 1.x sdk and provide the same functionality in the cutover.
I have not done any work on improving the existing code that can be done in a follow up PR.