airflow.providers.apache.kafka.hooks.produce¶
模块内容¶
类¶
用于创建 Kafka 生产者 的钩子。 |
- class airflow.providers.apache.kafka.hooks.produce.KafkaProducerHook(kafka_config_id=KafkaBaseHook.default_conn_name)[源代码]¶
基类:
airflow.providers.apache.kafka.hooks.base.KafkaBaseHook用于创建 Kafka 生产者 的钩子。
- 参数
kafka_config_id – 要使用的连接对象，默认为“kafka_default”