Function mz_kafka_util::admin::ensure_topic
source · pub async fn ensure_topic<'a, C>(
client: &'a AdminClient<C>,
admin_opts: &AdminOptions,
new_topic: &'a NewTopic<'a>
) -> Result<bool, CreateTopicError>where
C: ClientContext,
Expand description
Like create_new_topic
but allow topic to already exist