Stream Enrich Kafka: Enable AWS MSK IAM Authentication (close #547)

snowplow · Jan 27, 2022 · 3a7f43a · 3a7f43a
1 parent ee37882
commit 3a7f43a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/build.sbt b/build.sbt
@@ -126,7 +126,8 @@ lazy val streamKafka = project
     Docker / packageName := "stream-enrich-kafka",
   )
   .settings(libraryDependencies ++= Seq(
-    Dependencies.Libraries.kafkaClients
+    Dependencies.Libraries.kafkaClients,
+    Dependencies.Libraries.mskAuth
   ))
   .enablePlugins(JavaAppPackaging, DockerPlugin)
   .dependsOn(streamCommon)

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -67,6 +67,7 @@ object Dependencies {
     val gcpSdk           = "1.118.1"
     val kinesisClient    = "1.14.5"
     val kafka            = "2.2.1"
+    val mskAuth          = "1.1.1"
     val nsqClient        = "1.2.0"
     val jackson          = "2.11.4"
     val config           = "1.3.4"
@@ -154,6 +155,7 @@ object Dependencies {
     val sts              = "com.amazonaws"                    %  "aws-java-sdk-sts"                  % V.awsSdk           % Runtime
     val gcs              = "com.google.cloud"                 %  "google-cloud-storage"              % V.gcpSdk
     val kafkaClients     = "org.apache.kafka"                 %  "kafka-clients"                     % V.kafka
+    val mskAuth          = "software.amazon.msk"              %  "aws-msk-iam-auth"                  % V.mskAuth          % Runtime
     val jacksonCbor      = "com.fasterxml.jackson.dataformat" %  "jackson-dataformat-cbor"           % V.jackson
     val config           = "com.typesafe"                     %  "config"                            % V.config
     val log4jOverSlf4j   = "org.slf4j"                        %  "log4j-over-slf4j"                  % V.slf4j