`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]¶

Returns a producer object for sending messages to Kafka