Function mz_sql::kafka_util::fetch_end_offset

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