risingwave_connector::schema::protobuf

Function fetch_descriptor

source
pub async fn fetch_descriptor(
    format_options: &BTreeMap<String, String>,
    topic: &str,
    aws_auth_props: Option<&AwsAuthProps>,
) -> Result<(MessageDescriptor, Option<i32>), SchemaFetchError>
Expand description

aws_auth_props is only required when reading s3:// URL.