in source/lambda/msk-metadata/lambda_function.py [0:0]
def _get_bootstrap_brokers(cluster_arn):
response = client_kafka.get_bootstrap_brokers(ClusterArn=cluster_arn)
if 'BootstrapBrokerStringSaslScram' in response:
return response['BootstrapBrokerStringSaslScram']
if 'BootstrapBrokerStringSaslIam' in response:
return response['BootstrapBrokerStringSaslIam']
if 'BootstrapBrokerStringTls' in response:
return response['BootstrapBrokerStringTls']
return response['BootstrapBrokerString']