mz_sql::kafka_util

Function fetch_end_offset

Source 
fn fetch_end_offset<C>(
    consumer: &BaseConsumer<C>,
    topic: &str,
    pid: i32,
) -> Result<i64, PlanError>
where
    C: ConsumerContext,