Apache Kafka 钩子¶
KafkaHook¶
用于与 Apache Kafka 交互的基础钩子。创建自己的 Kafka Hooks 时，请使用此 Hook 作为基类。有关参数定义，请参阅 KafkaBaseHook。
KafkaAdminClientHook¶
用于与 Apache Kafka 集群交互的 Hook。有关参数定义，请参阅 KafkaAdminClientHook。
参考¶
更多信息，请参阅 Apache Kafka 管理配置文档。
KafkaAuthenticationError¶
Kafka 认证失败的自定义异常。
参考¶
更多信息，请参阅 Confluent Kafka 文档。
KafkaConsumerHook¶
用于创建 Kafka Consumer 的 Hook。此 Hook 由 ConsumeFromTopicOperator 和 AwaitMessageTrigger 使用。有关参数定义，请参阅 KafkaConsumerHook。
参考¶
更多信息，请参阅 Apache Kafka Consumer 文档。
KafkaProducerHook¶
用于创建 Kafka Producer 的 Hook。此 Hook 由 ProduceToTopicOperator 使用。有关参数定义，请参阅 KafkaProducerHook。
参考¶
更多信息，请参阅 Apache Kafka Producer 文档。