def should_try_kafka_again(error):
    """Determine if the error means to retry or fail, True to retry."""
    msg = 'Unable to retrieve'
    return isinstance(error, KafkaException) and str(error).startswith(msg)
def should_try_kafka_again ( error ) : msg = 'Unable to retrieve' return isinstance ( error , KafkaException ) and str ( error ) . startswith ( msg )
Determine if the error means to retry or fail, True to retry.