Function rd_kafka_CreateTopics

pub unsafe extern "C" fn rd_kafka_CreateTopics(
    rk: *mut rd_kafka_t,
    new_topics: *mut *mut rd_kafka_NewTopic_t,
    new_topic_cnt: usize,
    options: *const rd_kafka_AdminOptions_t,
    rkqu: *mut rd_kafka_queue_t,
)

Create topics in cluster as specified by the \p new_topics array of size `new_topic_cnt elements.

• rk: Client instance.
• new_topics: Array of new topics to create.
• new_topic_cnt: Number of elements in \p new_topics array.
• options: Optional admin options, or NULL for defaults.
• rkqu: Queue to emit result on.

Supported admin options:

• rd_kafka_AdminOptions_set_validate_only() - default false
• rd_kafka_AdminOptions_set_operation_timeout() - default 60 seconds
• rd_kafka_AdminOptions_set_request_timeout() - default socket.timeout.ms

@remark The result event type emitted on the supplied queue is of type `RD_KAFKA_EVENT_CREATETOPICS_RESULT