`airflow.providers.apache.kafka.hooks.client`¶

模块内容¶

类¶

KafkaAdminClientHook

用于与 Kafka 集群交互的钩子。

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

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

用于与 Kafka 集群交互的钩子。

参数: kafka_config_id – 要使用的连接对象，默认为 “kafka_default”

create_topic(topics)[源代码]¶

创建一个主题。

参数: topics (collections.abc.Sequence[collections.abc.Sequence[Any]]) – 要创建的主题列表，包括主题的分区数和复制因子。格式：[ (“topic_name”, 分区数, 复制因子)]

delete_topic(topics)[源代码]¶

删除一个主题。

参数: topics (collections.abc.Sequence[str]) – 要删除的主题列表。

此条目是否有帮助？