airflow.providers.apache.kafka.hooks.consume¶
异常¶
用于 Kafka 身份验证失败的自定义异常。 |
类¶
用于创建 Kafka Consumer 的钩子。 |
函数¶
|
处理 kafka 错误。 |
模块内容¶
- exception airflow.providers.apache.kafka.hooks.consume.KafkaAuthenticationError[source]¶
Bases:
Exception
用于 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]) – 要订阅的主题列表。