airflow.providers.apache.kafka.hooks.produce

模組內容

類別

KafkaProducerHook

用於建立 Kafka Producer 的鉤子。
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 的鉤子。

參數

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

get_producer()[source]

傳回用於發送訊息到 Kafka 的 producer 物件。

這個條目有幫助嗎？