async fn get_remote_csr_schema(
    ccsr_client: &Client,
    key_strategy: ReaderSchemaSelectionStrategy,
    value_strategy: ReaderSchemaSelectionStrategy,
    topic: String
) -> Result<Schema, PlanError>