指令碼開發 / 聯結器物件 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；連線或傳送失敗時丟擲異常。