Skip to main content

Module pulsar_resolver

risingwave_connector::parser::avro

Module pulsar_resolver 

Source

Structsยง

PulsarSchemaCache
Fetch schemas of a single Pulsar topic and cache writer schemas by version. Each parser configuration owns a resolver and shares it with its clones through Arc.