airflow.providers.apache.kafka.hooks.client

KafkaAdminClientHook

用于与 Kafka 集群交互的 Hook。

模块内容

airflow.providers.apache.kafka.hooks.client.KafkaAdminClientHook(kafka_config_id=KafkaBaseHook.default_conn_name)[源代码]

基类: airflow.providers.apache.kafka.hooks.base.KafkaBaseHook

用于与 Kafka 集群交互的 Hook。

参数:

kafka_config_id – 要使用的连接对象,默认为“kafka_default”

create_topic(topics)[源代码]

创建一个 topic。

参数:

**topics** (collections.abc.Sequence[collections.abc.Sequence[Any]]) – 要创建的 topic 列表,包括每个 topic 的分区数量和副本因子。格式:[ (“topic_name”, 分区数量, 副本因子)]

delete_topic(topics)[源代码]

删除一个 topic。

参数:

**topics** (collections.abc.Sequence[str]) – 要删除的 topic 列表。

此条目有帮助吗?