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 列表。