Function mz_sql::kafka_util::fetch_end_offset

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