Function mz_sql::kafka_util::ensure_topic_exists

source · 
pub async fn ensure_topic_exists<C>(
    consumer: Arc<BaseConsumer<C>>,
    topic: &str,
    fetch_metadata_timeout: Duration
) -> Result<(), PlanError>
where
    C: ConsumerContext + 'static,
Expand description

Validates that we can connect to the broker and obtain metadata about the topic.