risingwave_connector::sink::formatter::debezium_json

Function concat_debezium_name_field

source
fn concat_debezium_name_field(
    db_name: &str,
    sink_from_name: &str,
    value: &str,
) -> String