跳轉到

指令碼開發 / Kafka

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

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

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

.publish(...)

釋出訊息,引數如下:

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