airflow.providers.apache.kafka.hooks.produce¶
类¶
用于创建 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”