From f34241e4dfbe7223febeb71f8bdf344c779d3bea Mon Sep 17 00:00:00 2001
From: bhargav joshi <bhargav.joshi@gmail.com>
Date: Wed, 9 Oct 2024 16:21:59 -0400
Subject: [PATCH] Update application.conf

add MSK configuration
---
 .../src/main/resources/application.conf          | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/submission-errors/src/main/resources/application.conf b/submission-errors/src/main/resources/application.conf
index 05a3311d51..39d7814398 100644
--- a/submission-errors/src/main/resources/application.conf
+++ b/submission-errors/src/main/resources/application.conf
@@ -1,6 +1,20 @@
 kafka {
   hosts = "localhost:9092"
   hosts = ${?KAFKA_CLUSTER_HOSTS}
+  security.protocol="SASL_SSL"
+  security.protocol=${?KAFKA_SECURITY}
+  // ssl.truststore.location = ""
+  // ssl.truststore.location = ${?TRUSTSTORE_PATH}
+  // ssl.truststore.password = ""
+  // ssl.truststore.password = ${?TRUSTSTORE_PASSWORD}
+  // ssl.endpoint = ""
+  // ssl.endpoint = ${?KAFKA_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG}
+  sasl.mechanism="AWS_MSK_IAM"
+  //sasl.mechanism=${?KAFKA_SASL_MECHANISM}
+  sasl.jaas.config="software.amazon.msk.auth.iam.IAMLoginModule required;"
+  //sasl.jaas.config="{?KAFKA_SASL_JAAS_CONFIG}"
+  sasl.client.callback.handler.class="software.amazon.msk.auth.iam.IAMClientCallbackHandler"
+  //sasl.client.callback.handler.class="{?KAFKA_SASL_CLASS}"
 
   topic = "submission-errors"
   topic = ${?KAFKA_TOPIC}
@@ -60,4 +74,4 @@ submission-errors-db {
     connectionTimeout = 20000
     validationTimeout = 10000
   }
-}
\ No newline at end of file
+}