pub async fn fetch_from_registry( message_name: &str, format_options: &BTreeMap<String, String>, topic: &str, ) -> Result<(MessageDescriptor, i32), SchemaFetchError>