Function mz_sql::kafka_util::validate_start_offsets

pub async fn validate_start_offsets<C>(
    consumer: Arc<BaseConsumer<C>>,
    topic: &str,
    start_offsets: Vec<i64>,
    fetch_metadata_timeout: Duration,
) -> Result<(), PlanError>
where
    C: ConsumerContext + 'static,

Validates that the provided start offsets are valid for the specified topic. At present, the validation is merely that there are not more start offsets than parts in the topic.