腳本開發 / 連接器對象 DFF.CONN / Kafka

Kafka 連接器操作對象主要提供一些操作 Kafka 的方法。

DFF.CONN(...) 參數如下：

參數	類型	必須 / 默認值	説明
connector_id	str	必須	連接器 ID

消息訂閲

有關在連接器中進行消息訂閲，請參考 腳本開發 / 連接器訂閲

.publish(...)

發佈消息並等待 Kafka 確認發送結果，參數如下：

參數	類型	必須 / 默認值	説明
topic	str	必須	主題
message	str/bytes	必須	消息內容；字符串按 UTF-8 編碼

kafka.publish(topic='events', message='hello')

發送成功時返回 None；連接或發送失敗時拋出異常。