Module mz_kafka_util::admin

source ·
Expand description

Helpers for working with Kafka’s admin API.

Enums

CreateTopicError
An error while creating a Kafka topic.

Functions

create_new_topic
Creates a Kafka topic and waits for it to be reported in the broker metadata.
create_topic_helper 🔒
ensure_topic
Like create_new_topic but allow topic to already exist

Opaque Types

 🔒
 🔒
 🔒