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。

此条目有帮助吗？