risingwave_connector::schema::schema_registry

Function get_subject_by_strategy

source 
pub fn get_subject_by_strategy(
    name_strategy: &SchemaRegistryNameStrategy,
    topic: &str,
    record: Option<&str>,
    is_key: bool,
) -> Result<String, InvalidOptionError>