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

Module Contents¶

A hook for creating a Kafka Producer.

class airflow.providers.apache.kafka.hooks.produce.KafkaProducerHook(kafka_config_id=KafkaBaseHook.default_conn_name)[source]¶

A hook for creating a Kafka Producer.

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

get_producer()[source]¶

Return a producer object for sending messages to Kafka.