Module mz_kafka_util::admin

Helpers for working with Kafka’s admin API.

Enums

• CreateTopicError
  An error while creating a Kafka topic.
• DeleteTopicError
  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 🔒
• delete_existing_topic
  Deletes a Kafka topic and waits for it to be reported absent in the broker metadata.
• delete_topic
  Like delete_existing_topic but allow topic to be already deleted
• delete_topic_helper 🔒
• ensure_topic
  Like create_new_topic but allow topic to already exist