fix kafka sasl config

Author: zencircle

common/src/main/resources/persistence-keyspace-sigv4.conf

@@ -99,10 +99,16 @@ kafka {
   idle-timeout = ${?KAFKA_IDLE_TIMEOUT}
   security.protocol=""
   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}
+  # 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}"  
 }