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

模組內容¶

類別¶

KafkaConsumerHook

用於建立 Kafka Consumer 的 hook。

函數¶

error_callback(err)

處理 kafka 錯誤。

exception airflow.providers.apache.kafka.hooks.consume.KafkaAuthenticationError[source]¶

Bases: Exception

Kafka 驗證失敗的自訂例外。

airflow.providers.apache.kafka.hooks.consume.error_callback(err)[source]¶: 處理 kafka 錯誤。

class airflow.providers.apache.kafka.hooks.consume.KafkaConsumerHook(topics, kafka_config_id=KafkaBaseHook.default_conn_name)[source]¶

Bases: airflow.providers.apache.kafka.hooks.base.KafkaBaseHook

用於建立 Kafka Consumer 的 hook。

參數

kafka_config_id – 要使用的連線物件，預設為 "kafka_default"
topics (collections.abc.Sequence[str]) – 要訂閱的主題列表。

get_consumer()[source]¶

傳回已訂閱主題的 Consumer。

這個條目是否有幫助？