Update application.conf

add MSK configuration
cfpb · Oct 9, 2024 · f34241e · f34241e
1 parent fa534e0
commit f34241e
Showing 1 changed file with 15 additions and 1 deletion.
diff --git 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
   }
-}
+}