fn raise_key_value_errors( _: KV, ) -> Option<Result<(Option<Row>, Row), DataflowError>>
Handle possibly missing key or value portions of messages