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 文件。