airflow.providers.apache.kafka.hooks.client¶
模組內容¶
類別¶
用於與 Kafka 集群互動的 Hook。 |
- class 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)[來源]¶
建立主題。
- 參數
topics (collections.abc.Sequence[collections.abc.Sequence[Any]]) – 要建立的主題列表，包含主題的分區數量和複寫因子。格式：[ (“topic_name”, 分區數量, 複寫因子)]
- delete_topic(topics)[來源]¶
刪除主題。
- 參數
topics (collections.abc.Sequence[str]) – 要刪除的主題列表。