airflow.providers.apache.kafka.hooks.produce

類

KafkaProducerHook

用於建立 Kafka Producer 的 Hook。

模組內容

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

基類: airflow.providers.apache.kafka.hooks.base.KafkaBaseHook

用於建立 Kafka Producer 的 Hook。

引數：

kafka_config_id – 要使用的連線物件，預設為“kafka_default”

get_producer()[source]

返回一個用於向 Kafka 傳送訊息的 producer 物件。

此條目有幫助嗎？