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

Module Contents¶

Classes¶

KafkaBaseHook

A base hook for interacting with Apache Kafka.

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

Bases: airflow.hooks.base.BaseHook

A base hook for interacting with Apache Kafka.

Parameters: kafka_config_id – The connection object to use, defaults to “kafka_default”

conn_name_attr = 'kafka_config_id'[source]¶

default_conn_name = 'kafka_default'[source]¶

conn_type = 'kafka'[source]¶

hook_name = 'Apache Kafka'[source]¶

classmethod get_ui_field_behaviour()[source]¶

Return custom field behaviour.

get_conn()[source]¶

Get the configuration object.

test_connection()[source]¶

Test Connectivity from the UI.

Was this entry helpful?