Remove dependency on amazon-kinesis-client (close #68)

snowplow-incubator · Sep 12, 2023 · 5923b04 · 5923b04
1 parent a0c08ff
commit 5923b04
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -33,7 +33,7 @@ object Dependencies {
     val circe          = "0.14.1"
     val fs2Pubsub      = "0.22.0"
     val fs2Kafka       = "3.0.1"
-    val awsRegions     = "2.20.69"
+    val awsSdk         = "2.20.123"
     // Scala (test only)
     val specs2           = "4.12.3"
     val scalaCheck       = "1.14.0"
@@ -65,8 +65,8 @@ object Dependencies {
     val scalaCheckCats = "io.chrisdavenport"        %% "cats-scalacheck"              % V.scalaCheckCats
     val httpClient     = "org.apache.httpcomponents" % "httpclient"                   % V.httpClient
     val slf4j          = "org.slf4j"                 % "slf4j-simple"                 % V.slf4j
-    val kcl            = "software.amazon.kinesis"   % "amazon-kinesis-client"        % V.kcl
-    val awsRegions     = "software.amazon.awssdk"    % "regions"                      % V.awsRegions
+    val kcl            = "software.amazon.awssdk"    % "kinesis"                      % V.awsSdk
+    val awsRegions     = "software.amazon.awssdk"    % "regions"                      % V.awsSdk
     val http4sClient    = "org.http4s"        %% "http4s-blaze-client"           % V.http4s         
 
     // Scala (test only)

diff --git a/sinks/src/main/scala/com.snowplowanalytics.snowplow.eventgen/Main.scala b/sinks/src/main/scala/com.snowplowanalytics.snowplow.eventgen/Main.scala
@@ -24,7 +24,6 @@ import com.snowplowanalytics.snowplow.eventgen.protocol.event.UnstructEvent
 import software.amazon.awssdk.core.SdkBytes
 import software.amazon.awssdk.services.kinesis.KinesisAsyncClient
 import software.amazon.awssdk.services.kinesis.model.PutRecordRequest
-import software.amazon.kinesis.common.KinesisClientUtil
 import com.permutive.pubsub.producer.grpc.{GooglePubsubProducer, PubsubProducerConfig}
 import com.permutive.pubsub.producer.Model.{ProjectId, Topic}
 import com.permutive.pubsub.producer.encoder.MessageEncoder
@@ -180,9 +179,9 @@ object Main extends IOApp {
       }
       val kinesisClient: KinesisAsyncClient = output.region match {
         case Some(region) =>
-          KinesisClientUtil.createKinesisAsyncClient(KinesisAsyncClient.builder().region(Region.of(region)))
+          KinesisAsyncClient.builder.region(Region.of(region)).build
         case None =>
-          KinesisClientUtil.createKinesisAsyncClient(KinesisAsyncClient.builder())
+          KinesisAsyncClient.builder.build
       }
 
       def reqBuilder(event: Event): PutRecordRequest = PutRecordRequest