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

模块内容¶

类¶

KafkaConsumerHook

用于创建 Kafka 消费者的钩子。

函数¶

error_callback(err)

处理 Kafka 错误。

exception airflow.providers.apache.kafka.hooks.consume.KafkaAuthenticationError[源代码]¶

基类： Exception

Kafka 身份验证失败的自定义异常。

airflow.providers.apache.kafka.hooks.consume.error_callback(err)[源代码]¶: 处理 Kafka 错误。

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

基类： airflow.providers.apache.kafka.hooks.base.KafkaBaseHook

用于创建 Kafka 消费者的钩子。

参数

kafka_config_id – 要使用的连接对象，默认为 “kafka_default”
topics (collections.abc.Sequence[str]) – 要订阅的主题列表。

get_consumer()[源代码]¶

返回一个已订阅主题的消费者。

此条目是否对您有帮助？