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

Attributes¶

`CALLBACK_CONFIG_KEYS`
`MSK_BOOTSTRAP_SERVERS_REGEX`

A base hook for interacting with Apache Kafka.

airflow.providers.apache.kafka.hooks.base.CALLBACK_CONFIG_KEYS = ('error_cb', 'throttle_cb', 'stats_cb', 'log_cb', 'oauth_cb', 'on_commit')[source]¶

airflow.providers.apache.kafka.hooks.base.MSK_BOOTSTRAP_SERVERS_REGEX[source]¶

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

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.