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

类¶

KafkaBaseHook

用于与 Apache Kafka 交互的基础 Hook。

模块内容¶

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

继承自: airflow.hooks.base.BaseHook

用于与 Apache Kafka 交互的基础 Hook。

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

conn_name_attr = 'kafka_config_id'[源码]¶

default_conn_name = 'kafka_default'[源码]¶

conn_type = 'kafka'[源码]¶

hook_name = 'Apache Kafka'[源码]¶

kafka_config_id = 'kafka_default'[源码]¶

classmethod get_ui_field_behaviour()[源码]¶

返回自定义字段行为。

property get_conn: Any[源码]¶

获取配置对象。

test_connection()[源码]¶

从 UI 测试连接。

此条目有帮助吗？