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。

此条目有帮助吗?