Apache Kafka 钩子¶
KafkaHook¶
用于与 Apache Kafka 交互的基础钩子。在创建自定义 Kafka 钩子时，将此钩子用作基类。有关参数定义，请参阅 KafkaBaseHook。
KafkaAdminClientHook¶
用于与 Apache Kafka 集群交互的钩子。有关参数定义，请参阅 KafkaAdminClientHook。
参考¶
欲了解更多信息，请参阅 Apache Kafka Admin 配置文档。
KafkaAuthenticationError¶
Kafka 身份验证失败的自定义异常。
参考¶
欲了解更多信息，请参阅 Confluent Kafka 文档。
KafkaConsumerHook¶
用于创建 Kafka Consumer 的钩子。此钩子被 ConsumeFromTopicOperator 和 AwaitMessageTrigger 使用。有关参数定义，请参阅 KafkaConsumerHook。
Reference¶
欲了解更多信息，请参阅 Apache Kafka Consumer 文档。
KafkaProducerHook¶
用于创建 Kafka Producer 的钩子。此钩子被 ProduceToTopicOperator 使用。有关参数定义，请参阅 KafkaProducerHook。
参考¶
欲了解更多信息，请参阅 Apache Kafka Producer 文档。