Module admin

Helpers for working with Kafka’s admin API.

Enums

• DeleteTopicError
  An error while creating a Kafka topic.
• EnsureTopicConfig
  When the topic we want to ensure already exists, what happens?

Functions

• alter_topic_config
  Alter the current configuration for a particular topic.
• 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.
• ensure_topic_config
  Expect the current configuration for a particular topic to match a provided set of values. If there are other configs set, we will ignore them.
• get_topic_config
  Get the current configuration for a particular topic.