#!/bin/bash
echo "ssl.truststore.location=/tmp/kafka-truststore.jks
security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler " > client.config
echo "https://dlcdn.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz"

curl -OL https://dlcdn.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz
tar -xvf kafka_2.13-3.5.0.tgz
mv kafka_2.13-3.5.0 kafka
curl -OL https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.9/aws-msk-iam-auth-1.1.9-all.jar
mv aws-msk-iam-auth-1.1.9-all.jar kafka/libs/

java -version
cp $(readlink -f /usr/bin/java | sed "s:bin/java::")lib/security/cacerts /tmp/kafka-truststore.jks