airflow.providers.apache.kafka.hooks.client¶
类¶
用于与 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 列表。