腳本開發 / Kafka

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

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

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

消息訂閲

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

.publish(...)

發佈消息，參數如下：

參數	類型	必須 / 默認值	説明
topic	str	必須	主題
message	str	必須	消息內容