Migrate batch example to use the aws crt client

Author: jreijn

examples/powertools-examples-batch/pom.xml

@@ -14,7 +14,7 @@
         <maven.compiler.source>11</maven.compiler.source>
         <maven.compiler.target>11</maven.compiler.target>
         <aspectj.version>1.9.20.1</aspectj.version>
-        <sdk.version>2.21.1</sdk.version>
+        <sdk.version>2.22.0</sdk.version>
     </properties>
 
     <dependencies>
@@ -50,7 +50,7 @@
         </dependency>
         <dependency>
             <groupId>software.amazon.awssdk</groupId>
-            <artifactId>url-connection-client</artifactId>
+            <artifactId>aws-crt-client</artifactId>
             <version>${sdk.version}</version>
         </dependency>
         <dependency>

examples/powertools-examples-batch/src/main/java/org/demo/batch/dynamo/DynamoDBWriter.java

@@ -16,7 +16,6 @@
 import software.amazon.awssdk.enhanced.dynamodb.model.BatchWriteItemEnhancedRequest;
 import software.amazon.awssdk.enhanced.dynamodb.model.BatchWriteResult;
 import software.amazon.awssdk.enhanced.dynamodb.model.WriteBatch;
-import software.amazon.awssdk.http.urlconnection.UrlConnectionHttpClient;
 import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
 
 public class DynamoDBWriter implements RequestHandler<ScheduledEvent, String> {
@@ -30,7 +29,7 @@ public class DynamoDBWriter implements RequestHandler<ScheduledEvent, String> {
     public DynamoDBWriter() {
         random = new SecureRandom();
         DynamoDbClient dynamoDbClient = DynamoDbClient.builder()
-                .httpClientBuilder(UrlConnectionHttpClient.builder())
+                .httpClientBuilder(AwsCrtHttpClient.builder())
                 .build();
 
         enhancedClient = DynamoDbEnhancedClient.builder()

examples/powertools-examples-batch/src/main/java/org/demo/batch/kinesis/KinesisBatchSender.java

@@ -14,7 +14,7 @@
 import org.slf4j.LoggerFactory;
 import org.demo.batch.model.Product;
 import software.amazon.awssdk.core.SdkBytes;
-import software.amazon.awssdk.http.urlconnection.UrlConnectionHttpClient;
+import software.amazon.awssdk.http.crt.AwsCrtHttpClient;
 import software.amazon.awssdk.services.kinesis.KinesisClient;
 import software.amazon.awssdk.services.kinesis.model.PutRecordsRequest;
 import software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry;
@@ -36,7 +36,7 @@ public class KinesisBatchSender implements RequestHandler<ScheduledEvent, String
 
     public KinesisBatchSender() {
         kinesisClient = KinesisClient.builder()
-                .httpClient(UrlConnectionHttpClient.create())
+                .httpClient(AwsCrtHttpClient.create())
                 .build();
         random = new SecureRandom();
         objectMapper = new ObjectMapper();

examples/powertools-examples-batch/src/main/java/org/demo/batch/sqs/SqsBatchSender.java

@@ -13,7 +13,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.demo.batch.model.Product;
-import software.amazon.awssdk.http.urlconnection.UrlConnectionHttpClient;
+import software.amazon.awssdk.http.crt.AwsCrtHttpClient;
 import software.amazon.awssdk.services.sqs.SqsClient;
 import software.amazon.awssdk.services.sqs.model.SendMessageBatchRequest;
 import software.amazon.awssdk.services.sqs.model.SendMessageBatchRequestEntry;
@@ -35,7 +35,7 @@ public class SqsBatchSender implements RequestHandler<ScheduledEvent, String> {
 
     public SqsBatchSender() {
         sqsClient = SqsClient.builder()
-                .httpClient(UrlConnectionHttpClient.create())
+                .httpClient(AwsCrtHttpClient.create())
                 .build();
         random = new SecureRandom();
         objectMapper = new ObjectMapper();