def kafka_get_brokers()

in helpers/functions.py [0:0]

• 13 lines of code
• 3 McCabe index (conditional complexity)

def kafka_get_brokers() -> str:
    """ get msk brokers from the kafka arn """
    try:
        kafka_brokers = kafkaclient.get_bootstrap_brokers(ClusterArn=kafka_get_arn())
        return kafka_brokers["BootstrapBrokerString"]
    except ClientError as err:
        if (
            err.response["Error"]["Message"]
            == "Missing required request parameters: [clusterArn]"
        ):
            return ""
        else:
            print(f"Unexpectedd error: {err}")
    return ""