Module admin

Helpers for working with Kafka’s admin API.

Enums

• DeleteTopicError
  An error while creating a Kafka topic.

Functions

• 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
  Creates a Kafka topic if it does not exist, and waits for it to be reported in the broker metadata.