risingwave_stream::executor::backfill::cdc::cdc_backill_v2

Function is_reset_barrier

Source 
fn is_reset_barrier(barrier: &Barrier, actor_id: ActorId) -> bool