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

Classes¶

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.sdk.BaseHook

A base hook for interacting with Apache Kafka.

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

classmethod get_ui_field_behaviour()[source]¶

Return custom field behaviour.

property get_conn: Any[source]¶

Get the configuration object.

test_connection()[source]¶

Test Connectivity from the UI.