Function mz_sql::kafka_util::validate_start_offsets

source · 
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,
Expand description

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.