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