echo "Get kafka config from ssm"
export KAFKA_IAM_CONNECTION_STRING=$(aws ssm get-parameter --name "/$KAFKA_ENV/kafka/KAFKA_IAM_CONNECTION_STRING" --with-decryption  --query "Parameter.{Name:Value}"  --region $AWS_MSK_REGION --output text)


cat << EOF > config.json
{
    "kafkaBrokers": "${KAFKA_IAM_CONNECTION_STRING}",
    "awsRegion": "$AWS_MSK_REGION",
    "connectorPrefix": "$TOPIC_PREFIX",
    "dryRun": $DRY_RUN
}
EOF

echo "Config file:"
cat config.json