Skip to main content

validate_pulsar_schema_options

risingwave_frontend::handler::create_source::validate

Function validate_pulsar_schema_options 

Source 
fn validate_pulsar_schema_options(
    format_encode: &FormatEncodeOptions,
    connector: &str,
) -> Result<bool>
Expand description

Returns whether the Pulsar schema is used. The Pulsar schema options themselves are validated by PulsarSchemaConfig::from_options when building the parser config. Only the connector and format, which that config is unaware of, are checked here.