Method set_failures

lambda-events/src/event/streams/mod.rs:55–69

Set multiple failed item identifiers at once. This is a convenience method for setting all batch item failures in one call. It replaces any previously registered failures. Besides `item_identifiers`, the generated struct will use default field values for [`KinesisBatchItemFailure`]. Important**: This feature requires `FunctionResponseTypes: ReportBatchItemFailures` to be enabled in your Lambda

(&mut self, item_identifiers: I)

    /// to be enabled in your Lambda function's Kinesis event source mapping configuration.
    /// Without this setting, Lambda will retry the entire batch on any failure.
    pub fn set_failures<I, S>(&mut self, item_identifiers: I)
    where
        I: IntoIterator<Item = S>,
        S: Into<String>,
    {
        self.batch_item_failures = item_identifiers
            .into_iter()
            .map(|id| KinesisBatchItemFailure {
                item_identifier: Some(id.into()),
                #[cfg(feature = "catch-all-fields")]
                other: serde_json::Map::new(),
                ..Default::default()
            })
            .collect();
    }
}

/// `KinesisBatchItemFailure` is the individual record which failed processing.