mz_sql::pure

Function get_remote_csr_schema

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