pub fn validate_payload_columns( payload: &Payload, expected: &HashSet<String>, ) -> Result<()>
Check if payload keys match the expected columns.