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

異常¶

KafkaAuthenticationError

用於 Kafka 身份驗證失敗的自定義異常。

類¶

KafkaConsumerHook

用於建立 Kafka Consumer 的鉤子。

函式¶

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 的鉤子。

引數:

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

topics[source]¶

get_consumer()[source]¶

返回已訂閱主題的 Consumer。

此條目有幫助嗎？