fn decode_row_with_strict_pk( connector_name: &str, schema: &Schema, pk_indices: &[usize], decode: impl FnMut(usize, &Field) -> Result<Datum>, log_non_pk_error: impl FnMut(&str, Error), ) -> Result<OwnedRow>