def _get_bootstrap_brokers()

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']