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 对象。

此条目有帮助吗？