指令碼開發 / Kafka

Kafka 聯結器操作物件主要提供一些操作 Kafka 的方法。

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

引數	型別	必須 / 預設值	說明
connector_id	str	必須	聯結器 ID

訊息訂閱

有關在聯結器中進行訊息訂閱，請參考 指令碼開發 / 聯結器訂閱

.publish(...)

釋出訊息，引數如下：

引數	型別	必須 / 預設值	說明
topic	str	必須	主題
message	str	必須	訊息內容