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

模块内容¶

类¶

KafkaBaseHook

用于与 Apache Kafka 交互的基础钩子。

class airflow.providers.apache.kafka.hooks.base.KafkaBaseHook(kafka_config_id=default_conn_name, *args, **kwargs)[源代码]¶

基类: airflow.hooks.base.BaseHook

用于与 Apache Kafka 交互的基础钩子。

参数: kafka_config_id – 要使用的连接对象，默认为“kafka_default”

conn_name_attr = 'kafka_config_id'[源代码]¶

default_conn_name = 'kafka_default'[源代码]¶

conn_type = 'kafka'[源代码]¶

hook_name = 'Apache Kafka'[源代码]¶

classmethod get_ui_field_behaviour()[源代码]¶

返回自定义字段行为。

get_conn()[源代码]¶

获取配置对象。

test_connection()[源代码]¶

从 UI 测试连接性。

此条目是否有帮助？