code: def _deliver_errored_events(errstream, recs):
      
      rlogger.info("Going to handle %s failed events", len(recs))
      rlogger.info(
          "First failed event: %s", json.dumps(recs[0], indent=4))
  
      kinesis_stream = errstream.get("kinesis_stream")
      randomkey = str(uuid.uuid4())
      if kinesis_stream:
          send_to_kinesis_stream(
              recs,
              kinesis_stream,
              partition_key=errstream.get("partition_key", randomkey))
          rlogger.info("Sent errors to Kinesis stream '%s'", errstream)
  
      delivery_stream = errstream.get("firehose_delivery_stream")
      if delivery_stream:
          send_to_delivery_stream(errevents, delivery_stream)
          rlogger.info("Sent error payload to Firehose delivery stream '%s'",
                       delivery_stream)
docs: Deliver errors to error stream.