async fn get_schema_with_strategy( client: &Client, strategy: ReaderSchemaSelectionStrategy, subject: &str, ) -> Result<Option<String>, PlanError>