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.