risingwave_frontend::handler::create_source

Function extract_debezium_avro_table_pk_columns

source 
async fn extract_debezium_avro_table_pk_columns(
    info: &StreamSourceInfo,
    with_properties: &WithOptionsSecResolved,
) -> Result<Vec<String>, RwError>