bump: AWS auth, dynamodb, eventbridge, firehose, ... 2.36.3 (was 2.25.16) (#3234)

Author: scala-steward

docker-compose.yml

@@ -49,7 +49,7 @@ services:
         echo 'CREATE PRIMARY INDEX ON akkaquery USING GSI;' | cbq -c Administrator:password -e http://couchbase:8093
       "
   elasticmq:
-    image: softwaremill/elasticmq-native:1.5.8
+    image: softwaremill/elasticmq-native:1.6.15
     ports:
       - "9324:9324"
   dynamodb:

docs/src/main/paradox/aws-shared-configuration.md

@@ -25,20 +25,6 @@ Please make sure to configure a big enough thread pool for the Netty client to a
 if you share the client between multiple Sources, Sinks and Flows. For the SQS Sinks and Sources the sum of all
 `parallelism` (Source) and `maxInFlight` (Sink) must be less than or equal to the thread pool size.
 
-
-## AWS retry configuration
-
-The AWS SDK 2 supports request retrying with exponential backoff.
-
-The request retry behaviour is configurable via the @javadoc[SdkDefaultClientBuilder.overrideConfiguration](software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder#overrideConfiguration-software.amazon.awssdk.core.client.config.ClientOverrideConfiguration-) method by using the @javadoc[RetryPolicy](software.amazon.awssdk.core.retry.RetryPolicy).
-
-Scala
-: @@snip [snip](/dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala) { #awsRetryConfiguration }
-
-Java
-: @@snip [snip](/dynamodb/src/test/java/docs/javadsl/RetryTest.java) { #awsRetryConfiguration }
-
-
 ## AWS Access Keys
 
 Do not encode AWS Access Keys in your source code or in static configuration. Please refer to [Best Practices for Managing AWS Access Keys](https://docs.aws.amazon.com/general/latest/gr/aws-access-keys-best-practices.html) for proper AWS Access Key management.

docs/src/main/paradox/dynamodb.md

@@ -91,18 +91,6 @@ Java
 : @@snip [snip](/dynamodb/src/test/java/docs/javadsl/ExampleTest.java) { #paginated }
 
 
-## Error Retries and Exponential Backoff
-
-The AWS SDK 2 implements error retrying with exponential backoff which is configurable via the @javadoc[DynamoDbAsyncClient](software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient) configuration by using the @javadoc[RetryPolicy](software.amazon.awssdk.core.retry.RetryPolicy) in `overrideConfiguration`.
-
-See @ref[AWS Retry configuration](aws-shared-configuration.md) for more details.
-
-Scala
-: @@snip [snip](/dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala) { #clientRetryConfig }
-
-Java
-: @@snip [snip](/dynamodb/src/test/java/docs/javadsl/RetryTest.java) { #clientRetryConfig }
-
 @@@ index
 
 * [retry conf](aws-shared-configuration.md)

dynamodb/src/test/java/docs/javadsl/RetryTest.java

@@ -18,7 +18,8 @@ object Dependencies {
 
   val InfluxDBJavaVersion = "2.15"
 
-  val AwsSdk2Version = "2.25.16"
+  // https://github.com/aws/aws-sdk-java-v2
+  val AwsSdk2Version = "2.36.3"
   val AwsSpiAkkaHttpVersion = "1.0.1"
   // Sync with plugins.sbt
   val AkkaGrpcBinaryVersion = "2.5"

dynamodb/src/test/scala/docs/scaladsl/RetrySpec.scala

@@ -8,7 +8,6 @@ import java.nio.file.{Path, Paths}
 import java.time.{Duration => JavaDuration}
 import java.util.concurrent.TimeUnit
 import java.util.{Objects, Optional}
-
 import akka.actor.{ActorSystem, ClassicActorSystemProvider}
 import akka.http.scaladsl.model.Uri
 import akka.stream.alpakka.s3.AccessStyle.{PathAccessStyle, VirtualHostAccessStyle}
@@ -590,13 +589,13 @@ object S3Settings {
       if (c.hasPath(credProviderPath)) {
         c.getString(credProviderPath) match {
           case "default" =>
-            DefaultCredentialsProvider.create()
+            DefaultCredentialsProvider.builder().build()
 
           case "static" =>
             val aki = c.getString("aws.credentials.access-key-id")
             val sak = c.getString("aws.credentials.secret-access-key")
             val tokenPath = "aws.credentials.token"
-            val creds = if (c.hasPath(tokenPath)) {
+            val creds: AwsCredentials = if (c.hasPath(tokenPath)) {
               AwsSessionCredentials.create(aki, sak, c.getString(tokenPath))
             } else {
               AwsBasicCredentials.create(aki, sak)
@@ -607,10 +606,10 @@ object S3Settings {
             AnonymousCredentialsProvider.create()
 
           case _ =>
-            DefaultCredentialsProvider.create()
+            DefaultCredentialsProvider.builder().build()
         }
       } else {
-        DefaultCredentialsProvider.create()
+        DefaultCredentialsProvider.builder().build()
       }
     }
 

project/Dependencies.scala

@@ -34,7 +34,7 @@ object SqsSource {
           ReceiveMessageRequest
             .builder()
             .queueUrl(queueUrl)
-            .attributeNamesWithStrings(settings.attributeNames.map(_.name).asJava)
+            .messageSystemAttributeNamesWithStrings(settings.attributeNames.map(_.name).asJava)
             .messageAttributeNames(settings.messageAttributeNames.map(_.name).asJava)
             .maxNumberOfMessages(settings.maxBatchSize)
             .waitTimeSeconds(settings.waitTimeSeconds)