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.