risingwave_stream::executor::source::source_backfill_executor

Function compare_kafka_offset

Source 
fn compare_kafka_offset(a: &str, b: &str) -> Ordering