Function mz_kafka_util::admin::create_topic_helper
source · async fn create_topic_helper<'a, C>(
client: &'a AdminClient<C>,
admin_opts: &AdminOptions,
new_topic: &'a NewTopic<'a>,
allow_existing: bool
) -> Result<bool, CreateTopicError>where
C: ClientContext,