腳本開發 / 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 | 必須 | 消息內容 |