Skip to main content

fetch_pulsar_json_schema_and_map_to_columns

risingwave_connector::parser

Function fetch_pulsar_json_schema_and_map_to_columns 

Source 
pub async fn fetch_pulsar_json_schema_and_map_to_columns(
    config: &PulsarSchemaConfig,
    props: &BTreeMap<String, String>,
) -> ConnectorResult<Vec<Field>>
Expand description

Fetches the latest Pulsar JSON schema of the source topic and maps it to columns.

Pulsar stores JSON schemas as Avro record definitions, while payloads are plain JSON without a schema-registry header. JSON is self-describing, so only the latest schema is needed.