Function kafka_util::admin::create_topic_helper[][src]

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