指令碼開發 / Kafka
Kafka 聯結器操作物件主要提供一些操作 Kafka 的方法。
DFF.CONN(...)
引數如下:
引數 | 型別 | 必須 / 預設值 | 說明 |
---|---|---|---|
connector_id |
str | 必須 | 聯結器 ID |
.publish(...)
釋出訊息,引數如下:
引數 | 型別 | 必須 / 預設值 | 說明 |
---|---|---|---|
topic |
str | 必須 | 主題 |
message |
str | 必須 | 訊息內容 |
Kafka 聯結器操作物件主要提供一些操作 Kafka 的方法。
DFF.CONN(...)
引數如下:
引數 | 型別 | 必須 / 預設值 | 說明 |
---|---|---|---|
connector_id |
str | 必須 | 聯結器 ID |
.publish(...)
釋出訊息,引數如下:
引數 | 型別 | 必須 / 預設值 | 說明 |
---|---|---|---|
topic |
str | 必須 | 主題 |
message |
str | 必須 | 訊息內容 |