Apache Kafka 钩子¶
KafkaHook¶
用于与 Apache Kafka 交互的基础钩子。创建您自己的 Kafka 钩子时，请以此钩子作为基类。有关参数定义，请查看KafkaBaseHook。
KafkaAdminClientHook¶
用于与 Apache Kafka 集群交互的钩子。有关参数定义，请查看KafkaAdminClientHook。
参考¶
有关更多信息，请查看Apache Kafka Admin 配置文档。
KafkaConsumerHook¶
用于创建 Kafka 消费者的钩子。此钩子由 ConsumeFromTopicOperator 和 AwaitMessageTrigger 使用。有关参数定义，请查看KafkaConsumerHook。
参考¶
有关更多信息，请查看Apache Kafka 消费者文档。
KafkaProducerHook¶
用于创建 Kafka 生Producer的钩子。此钩子由 ProduceToTopicOperator 使用。有关参数定义，请查看KafkaProducerHook。
参考¶
有关更多信息，请查看Apache Kafka 生产者文档。