risingwave_stream::executor::backfill::cdc::cdc_backfill

Function parse_debezium_chunk

Source 
async fn parse_debezium_chunk(
    parser: &mut DebeziumParser,
    chunk: &StreamChunk,
) -> StreamExecutorResult<StreamChunk>