docs: 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)